l2/subscript/l2_subscript_manager.py
@@ -7,7 +7,6 @@ import threading import time import msgpack import zmq from huaxin_client import l2_data_transform_protocol @@ -69,6 +68,8 @@ self.__queue_codes[queue_id].add(code) self.__code_queue_dict[code] = queue_id break # 分配订阅信息 logger_debug.info(f"订阅通道分配：{self.__code_queue_dict}") return [(self.__com_queue_id_object_dict.get(queue_id), self.__queue_codes[queue_id]) for queue_id in self.__queue_codes]
