l2/subscript/l2_subscript_manager.py | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
l2/subscript/l2_subscript_manager.py
@@ -69,6 +69,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]