[2024-07-01 16:23:13.879431 +08:00][saas_zmq::tests:183][DEBUG][ThreadId(7)] DEBUG output enabled
[2024-07-01 16:23:13.879543 +08:00][saas_zmq::request:185][INFO][ThreadId(5)] ZmqRequestManager create ZmqRequester
[2024-07-01 16:23:13.879635 +08:00][saas_zmq::subscribe:41][DEBUG][ThreadId(8)] do_subscribe ["B/m/l/btcusdt", "B/m/l/ethusdt", "B/m/l/ltcusdt", "B/m/l/eosusdt", "B/m/l/bchusdt", "B/m/l/trxusdt", "B/m/l/filusdt", "B/m/l/linkusdt", "B/m/l/dotusdt", "B/m/l/xrpusdt", "B/m/l/dogeusdt", "B/m/l/shibusdt", "B/m/l/adausdt", "B/m/l/maticusdt", "B/m/l/solusdt", "B/m/l/bnbusdt", "B/m/l/avaxusdt", "B/m/l/manausdt", "B/m/l/axsusdt", "B/m/l/uniusdt", "B/m/l/opusdt", "B/m/l/blurusdt", "B/m/l/wldusdt", "B/m/l/compusdt", "B/m/l/pepeusdt", "B/m/l/blzusdt", "B/m/l/cyberusdt", "B/m/l/bigtimeusdt", "B/m/l/trbusdt", "B/m/l/arbusdt", "B/m/l/ordiusdt", "B/m/l/memeusdt", "B/m/l/atomusdt", "B/m/l/bsvusdt", "B/m/l/seiusdt"]
[2024-07-01 16:23:13.879779 +08:00][saas_zmq::tests:184][INFO][ThreadId(7)] INFO output enabled
[2024-07-01 16:23:13.880243 +08:00][saas_zmq::tests:185][WARN][ThreadId(7)] WARN output enabled
[2024-07-01 16:23:13.880340 +08:00][saas_zmq::tests:186][ERROR][ThreadId(7)] ERROR output enabled
[2024-07-01 16:23:13.880694 +08:00][saas_zmq::common:37][DEBUG][ThreadId(6)] pub-fed conf load Config { peers: [PubFedConf { sub_bind: "tcp://localhost:8002", pub_bind: "tcp://localhost:8001", heartbeat_bind: "tcp://localhost:19001", req_tc_bind: "tcp://localhost:8081", rep_tc_bind: "tcp://localhost:8011", req_kc_bind: "tcp://localhost:8181", rep_kc_bind: "tcp://localhost:8111" }, PubFedConf { sub_bind: "tcp://localhost:8005", pub_bind: "tcp://localhost:8004", heartbeat_bind: "tcp://localhost:19002", req_tc_bind: "tcp://localhost:8082", rep_tc_bind: "tcp://localhost:8012", req_kc_bind: "tcp://localhost:8182", rep_kc_bind: "tcp://localhost:8112" }, PubFedConf { sub_bind: "tcp://localhost:8008", pub_bind: "tcp://localhost:8007", heartbeat_bind: "tcp://localhost:19003", req_tc_bind: "tcp://localhost:8083", rep_tc_bind: "tcp://localhost:8013", req_kc_bind: "tcp://localhost:8183", rep_kc_bind: "tcp://localhost:8113" }] }
[2024-07-01 16:23:13.881219 +08:00][saas_zmq::request:81][DEBUG][ThreadId(7)] ZmqRequest address ["tcp://localhost:8183"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.881222 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.881151 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.881145 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.881150 +08:00][saas_zmq::request:81][DEBUG][ThreadId(2)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.882193 +08:00][saas_zmq::common:59][INFO][ThreadId(6)] heartbeat_sub: "tcp://localhost:19001"
[2024-07-01 16:23:13.882196 +08:00][saas_zmq::common:59][INFO][ThreadId(8)] heartbeat_sub: "tcp://localhost:19001"
[2024-07-01 16:23:13.882547 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.882991 +08:00][saas_zmq::common:59][INFO][ThreadId(7)] heartbeat_sub: "tcp://localhost:19003"
[2024-07-01 16:23:13.883029 +08:00][saas_zmq::common:59][INFO][ThreadId(5)] heartbeat_sub: "tcp://localhost:19001"
[2024-07-01 16:23:13.883525 +08:00][saas_zmq::subscribe:74][INFO][ThreadId(8)] subscriber  ["tcp://localhost:8002"] topics ["B/m/l/btcusdt", "B/m/l/ethusdt", "B/m/l/ltcusdt", "B/m/l/eosusdt", "B/m/l/bchusdt", "B/m/l/trxusdt", "B/m/l/filusdt", "B/m/l/linkusdt", "B/m/l/dotusdt", "B/m/l/xrpusdt", "B/m/l/dogeusdt", "B/m/l/shibusdt", "B/m/l/adausdt", "B/m/l/maticusdt", "B/m/l/solusdt", "B/m/l/bnbusdt", "B/m/l/avaxusdt", "B/m/l/manausdt", "B/m/l/axsusdt", "B/m/l/uniusdt", "B/m/l/opusdt", "B/m/l/blurusdt", "B/m/l/wldusdt", "B/m/l/compusdt", "B/m/l/pepeusdt", "B/m/l/blzusdt", "B/m/l/cyberusdt", "B/m/l/bigtimeusdt", "B/m/l/trbusdt", "B/m/l/arbusdt", "B/m/l/ordiusdt", "B/m/l/memeusdt", "B/m/l/atomusdt", "B/m/l/bsvusdt", "B/m/l/seiusdt"]
[2024-07-01 16:23:13.883614 +08:00][saas_zmq::common:59][INFO][ThreadId(6)] heartbeat_sub: "tcp://localhost:19001"
[2024-07-01 16:23:13.883848 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.885065 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.886224 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.887235 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.888702 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.889857 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.890806 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.891665 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.892665 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.894045 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.895166 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.896020 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.896873 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.897587 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.898315 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.899043 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.899802 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:13.900455 +08:00][saas_zmq::request:81][DEBUG][ThreadId(4)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:14.216313 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 0 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.216821 +08:00][saas_zmq::tests:124][INFO][ThreadId(5)] Got response >>> 0
[2024-07-01 16:23:14.217055 +08:00][saas_zmq::tests:65][INFO][ThreadId(3)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.217092 +08:00][saas_zmq::request:190][INFO][ThreadId(5)] ZmqRequestManager recycle ZmqRequester
[2024-07-01 16:23:14.217159 +08:00][saas_zmq::tests:104][INFO][ThreadId(7)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.217210 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:14.217285 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:14.217363 +08:00][saas_zmq::request:169][INFO][ThreadId(7)] Abort heartbeat join handle.
[2024-07-01 16:23:14.218340 +08:00][saas_zmq::tests:56][INFO][ThreadId(2)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.218377 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 1 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.220264 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 2 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.220803 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 3 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.221424 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 4 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.223062 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 5 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.223655 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 6 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.224298 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 7 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.225853 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 8 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.226364 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 9 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.227954 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 10 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.229513 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 11 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.231197 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 12 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.231664 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 13 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.232323 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 14 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.232880 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 15 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.233432 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 16 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.233900 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 17 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.234421 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 18 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.235975 +08:00][saas_zmq::tests:78][INFO][ThreadId(4)] 19 response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.552807 +08:00][saas_zmq::tests:65][INFO][ThreadId(3)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.552826 +08:00][saas_zmq::tests:124][INFO][ThreadId(5)] Got response >>> 1
[2024-07-01 16:23:14.552979 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:14.553057 +08:00][saas_zmq::request:190][INFO][ThreadId(5)] ZmqRequestManager recycle ZmqRequester
[2024-07-01 16:23:14.553254 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:14.863187 +08:00][saas_zmq::tests:46][INFO][ThreadId(8)] markprice_msg_rx message: Ok("B/m/l/btcusdt")
[2024-07-01 16:23:14.863318 +08:00][saas_zmq::tests:46][INFO][ThreadId(8)] markprice_msg_rx message: Ok("{\"symbol\":\"btcusdt\",\"eventTs\":1719822195003,\"receiveTs\":1719822194862,\"tickerSource\":\"BINANCE\",\"marketType\":\"MARKPRICE\",\"markPrice\":63132.66215701}")
[2024-07-01 16:23:14.888393 +08:00][saas_zmq::tests:65][INFO][ThreadId(3)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:14.888427 +08:00][saas_zmq::tests:124][INFO][ThreadId(5)] Got response >>> 2
[2024-07-01 16:23:14.888580 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:14.888669 +08:00][saas_zmq::request:190][INFO][ThreadId(5)] ZmqRequestManager recycle ZmqRequester
[2024-07-01 16:23:14.889088 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:15.223399 +08:00][saas_zmq::tests:124][INFO][ThreadId(5)] Got response >>> 3
[2024-07-01 16:23:15.223590 +08:00][saas_zmq::request:190][INFO][ThreadId(5)] ZmqRequestManager recycle ZmqRequester
[2024-07-01 16:23:15.223727 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:15.223818 +08:00][saas_zmq::tests:65][INFO][ThreadId(3)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:15.224005 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:15.558783 +08:00][saas_zmq::tests:124][INFO][ThreadId(5)] Got response >>> 4
[2024-07-01 16:23:15.558908 +08:00][saas_zmq::tests:65][INFO][ThreadId(3)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:15.558947 +08:00][saas_zmq::request:190][INFO][ThreadId(5)] ZmqRequestManager recycle ZmqRequester
[2024-07-01 16:23:15.559042 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:15.559109 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:15.869527 +08:00][saas_zmq::tests:46][INFO][ThreadId(8)] markprice_msg_rx message: Ok("B/m/l/btcusdt")
[2024-07-01 16:23:15.869694 +08:00][saas_zmq::tests:46][INFO][ThreadId(8)] markprice_msg_rx message: Ok("{\"symbol\":\"btcusdt\",\"eventTs\":1719822196000,\"receiveTs\":1719822195868,\"tickerSource\":\"BINANCE\",\"marketType\":\"MARKPRICE\",\"markPrice\":63133.02287601}")
[2024-07-01 16:23:15.893681 +08:00][saas_zmq::tests:124][INFO][ThreadId(5)] Got response >>> 5
[2024-07-01 16:23:15.893889 +08:00][saas_zmq::request:190][INFO][ThreadId(5)] ZmqRequestManager recycle ZmqRequester
[2024-07-01 16:23:15.894010 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:15.894055 +08:00][saas_zmq::tests:65][INFO][ThreadId(3)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:15.894281 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:16.229198 +08:00][saas_zmq::tests:124][INFO][ThreadId(5)] Got response >>> 6
[2024-07-01 16:23:16.229198 +08:00][saas_zmq::tests:65][INFO][ThreadId(3)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:16.229354 +08:00][saas_zmq::request:190][INFO][ThreadId(5)] ZmqRequestManager recycle ZmqRequester
[2024-07-01 16:23:16.229410 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:16.229489 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:16.564340 +08:00][saas_zmq::tests:65][INFO][ThreadId(3)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:16.564478 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:16.565272 +08:00][saas_zmq::tests:124][INFO][ThreadId(5)] Got response >>> 7
[2024-07-01 16:23:16.565398 +08:00][saas_zmq::request:190][INFO][ThreadId(5)] ZmqRequestManager recycle ZmqRequester
[2024-07-01 16:23:16.565496 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:16.888608 +08:00][saas_zmq::tests:46][INFO][ThreadId(8)] markprice_msg_rx message: Ok("B/m/l/btcusdt")
[2024-07-01 16:23:16.888817 +08:00][saas_zmq::tests:46][INFO][ThreadId(8)] markprice_msg_rx message: Ok("{\"symbol\":\"btcusdt\",\"eventTs\":1719822197000,\"receiveTs\":1719822196886,\"tickerSource\":\"BINANCE\",\"marketType\":\"MARKPRICE\",\"markPrice\":63139.4}")
[2024-07-01 16:23:16.899792 +08:00][saas_zmq::tests:65][INFO][ThreadId(3)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:16.899981 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:16.901090 +08:00][saas_zmq::tests:124][INFO][ThreadId(5)] Got response >>> 8
[2024-07-01 16:23:16.901241 +08:00][saas_zmq::request:190][INFO][ThreadId(5)] ZmqRequestManager recycle ZmqRequester
[2024-07-01 16:23:16.901326 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:17.234985 +08:00][saas_zmq::tests:65][INFO][ThreadId(3)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:17.235134 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:17.235918 +08:00][saas_zmq::tests:124][INFO][ThreadId(5)] Got response >>> 9
[2024-07-01 16:23:17.236045 +08:00][saas_zmq::request:190][INFO][ThreadId(5)] ZmqRequestManager recycle ZmqRequester
[2024-07-01 16:23:17.236142 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:17.570161 +08:00][saas_zmq::tests:65][INFO][ThreadId(3)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:17.570356 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:17.570410 +08:00][saas_zmq::tests:124][INFO][ThreadId(5)] Got response >>> 10
[2024-07-01 16:23:17.570659 +08:00][saas_zmq::request:190][INFO][ThreadId(5)] ZmqRequestManager recycle ZmqRequester
[2024-07-01 16:23:17.570750 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:17.861276 +08:00][saas_zmq::tests:46][INFO][ThreadId(8)] markprice_msg_rx message: Ok("B/m/l/btcusdt")
[2024-07-01 16:23:17.861402 +08:00][saas_zmq::tests:46][INFO][ThreadId(8)] markprice_msg_rx message: Ok("{\"symbol\":\"btcusdt\",\"eventTs\":1719822198000,\"receiveTs\":1719822197860,\"tickerSource\":\"BINANCE\",\"marketType\":\"MARKPRICE\",\"markPrice\":63132.44457814}")
[2024-07-01 16:23:17.905949 +08:00][saas_zmq::tests:124][INFO][ThreadId(5)] Got response >>> 11
[2024-07-01 16:23:17.906378 +08:00][saas_zmq::request:190][INFO][ThreadId(5)] ZmqRequestManager recycle ZmqRequester
[2024-07-01 16:23:17.906545 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:17.906612 +08:00][saas_zmq::tests:65][INFO][ThreadId(3)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:17.907022 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:18.242835 +08:00][saas_zmq::tests:65][INFO][ThreadId(3)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:18.242846 +08:00][saas_zmq::tests:124][INFO][ThreadId(5)] Got response >>> 12
[2024-07-01 16:23:18.242977 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:18.243055 +08:00][saas_zmq::request:190][INFO][ThreadId(5)] ZmqRequestManager recycle ZmqRequester
[2024-07-01 16:23:18.243268 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:18.577855 +08:00][saas_zmq::tests:65][INFO][ThreadId(3)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:18.578020 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:18.578085 +08:00][saas_zmq::tests:124][INFO][ThreadId(5)] Got response >>> 13
[2024-07-01 16:23:18.578293 +08:00][saas_zmq::request:190][INFO][ThreadId(5)] ZmqRequestManager recycle ZmqRequester
[2024-07-01 16:23:18.578382 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:18.861312 +08:00][saas_zmq::tests:46][INFO][ThreadId(8)] markprice_msg_rx message: Ok("B/m/l/btcusdt")
[2024-07-01 16:23:18.861485 +08:00][saas_zmq::tests:46][INFO][ThreadId(8)] markprice_msg_rx message: Ok("{\"symbol\":\"btcusdt\",\"eventTs\":1719822199000,\"receiveTs\":1719822198860,\"tickerSource\":\"BINANCE\",\"marketType\":\"MARKPRICE\",\"markPrice\":63132.2}")
[2024-07-01 16:23:18.912639 +08:00][saas_zmq::tests:124][INFO][ThreadId(5)] Got response >>> 14
[2024-07-01 16:23:18.912633 +08:00][saas_zmq::tests:65][INFO][ThreadId(3)] response >>> Err(TIMEOUT)
[2024-07-01 16:23:18.912820 +08:00][saas_zmq::request:190][INFO][ThreadId(5)] ZmqRequestManager recycle ZmqRequester
[2024-07-01 16:23:18.912877 +08:00][saas_zmq::request:81][DEBUG][ThreadId(3)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }
[2024-07-01 16:23:18.912954 +08:00][saas_zmq::request:81][DEBUG][ThreadId(5)] ZmqRequest address ["tcp://localhost:8181"] >>> ZmqRequest { server: KlineCache, timeout: 333ms, request_info: ZmqRequestInfo { url: "get/kline/", param: {"symbole": "btcusdt"}, others: None } }