|
|
|
|
@ -54,7 +54,8 @@ import System.ZMQ4 (Context, Event (In),
@@ -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
@@ -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 |
|
|
|
|
|