diff --git a/src/ATrade/Broker/Client.hs b/src/ATrade/Broker/Client.hs index f52caf0..e55b866 100644 --- a/src/ATrade/Broker/Client.hs +++ b/src/ATrade/Broker/Client.hs @@ -54,7 +54,8 @@ import System.ZMQ4 (Context, Event (In), Sub (Sub), Switch (On), connect, poll, receive, receiveMulti, restrict, send, - setLinger, setTcpKeepAlive, + setLinger, setReqCorrelate, + setReqRelaxed, setTcpKeepAlive, setTcpKeepAliveCount, setTcpKeepAliveIdle, setTcpKeepAliveInterval, @@ -101,6 +102,8 @@ brokerClientThread socketIdentity ctx ep cmd comp killMv secParams logger = fina else do return ()) $ withSocket ctx Req (\sock -> do setLinger (restrict 0) sock + setReqCorrelate True sock + setReqRelaxed True sock case cspCertificate secParams of Just clientCert -> zapApplyCertificate clientCert sock