huaxin_api/l2_client.py
@@ -11,6 +11,7 @@ import lev2mdapi from huaxin_api.command_manager import L2ActionCallback from huaxin_api.mylog import logger_l2_orderdetail, logger_l2_transaction, logger_l2_subscript from log_module import log Front_Address = "tcp://10.0.1.101:6900" Multicast_Address = "udp://224.224.2.19:7889" @@ -536,6 +537,7 @@ def run(pipe_trade, pipe_strategy): log.close_print() if pipe_trade is not None: t1 = threading.Thread(target=lambda: __receive_from_pipe_trade(pipe_trade), daemon=True) t1.start()
