From c0bcfe746b97bc126636a658b1f01fc6a51f9f95 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 25 九月 2023 17:55:33 +0800
Subject: [PATCH] 将华鑫订单交易成功独立出来处理
---
huaxin_client/command_manager.py | 9 ++++-----
1 files changed, 4 insertions(+), 5 deletions(-)
diff --git a/huaxin_client/command_manager.py b/huaxin_client/command_manager.py
index 392241d..df18406 100644
--- a/huaxin_client/command_manager.py
+++ b/huaxin_client/command_manager.py
@@ -74,11 +74,10 @@
return cls._instance
@classmethod
- def init(cls, trade_action_callback: TradeActionCallback, pipe_l2, pipe_strategy, queue_strategy_trade):
+ def init(cls, trade_action_callback: TradeActionCallback, pipe_l2, queue_strategy_trade_read: multiprocessing.Queue):
cls.action_callback = trade_action_callback
- cls.pipe_strategy = pipe_strategy
cls.pipe_l2 = pipe_l2
- cls.queue_strategy_trade = queue_strategy_trade
+ cls.queue_strategy_trade_read = queue_strategy_trade_read
@classmethod
def process_command(cls, _type, client_id, result_json, sk=None):
@@ -144,10 +143,10 @@
# 缁存姢杩炴帴鏁扮殑绋冲畾
def run(self, blocking=True):
if blocking:
- self.run_process_command(self.queue_strategy_trade)
+ self.run_process_command(self.queue_strategy_trade_read)
else:
# 鎺ュ彈鍛戒护
- t1 = threading.Thread(target=lambda: self.run_process_command(self.queue_strategy_trade), daemon=True)
+ t1 = threading.Thread(target=lambda: self.run_process_command(self.queue_strategy_trade_read), daemon=True)
t1.start()
--
Gitblit v1.8.0