From eb33b717023d9871bd74e6dce47a065228cffefc Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期四, 02 十一月 2023 11:23:09 +0800 Subject: [PATCH] L2进程与策略进程分开 --- outside_api_command_manager.py | 10 +++++++++- 1 files changed, 9 insertions(+), 1 deletions(-) diff --git a/outside_api_command_manager.py b/outside_api_command_manager.py index 7e4035f..a476003 100644 --- a/outside_api_command_manager.py +++ b/outside_api_command_manager.py @@ -54,7 +54,9 @@ API_TYPE_SYNC_L1_TARGET_CODES = "sync_l1_subscript_codes" # 鍚屾L1闇�瑕佽闃呯殑浠g爜 API_TYPE_SYSTEM_LOG = "system_log" # 绯荤粺鏃ュ織 API_TYPE_GET_FROM_DATA_SERVER = "get_from_data_server" # 浠庢暟鎹湇鍔″櫒鎷夊彇鏁版嵁 -API_TYPE_CODE_TRADE_INFO = "code_trade_info" +API_TYPE_CODE_TRADE_INFO = "code_trade_info" # 浠g爜浜ゆ槗淇℃伅 +API_TYPE_CODE_L2_LISTEN_ACTIVE_COUNT = "l2_listen_active_count" # L2鏈夋晥鐩戝惉鏁伴噺 + class ActionCallback(object): # 浜ゆ槗 @@ -99,6 +101,9 @@ # 浠g爜鐨勪氦鏄撲俊鎭� def OnGetCodeTradeInfo(self, client_id, request_id, data): + pass + + def OnGetActiveListenCount(self, client_id, request_id): pass @@ -202,6 +207,9 @@ cls.action_callback.OnGetFromDataServer(client_id, request_id, data) elif content_type == API_TYPE_CODE_TRADE_INFO: cls.action_callback.OnGetCodeTradeInfo(client_id, request_id, data) + elif content_type == API_TYPE_CODE_L2_LISTEN_ACTIVE_COUNT: + cls.action_callback.OnGetActiveListenCount(client_id, request_id) + except Exception as e: logging.exception(e) pass -- Gitblit v1.8.0