|
|
|
@ -157,6 +157,7 @@ brokerClientThread socketIdentity ep cmd comp killMv notificationCallbacks logge |
|
|
|
handleMessage respVar (IncomingResponse resp) = do |
|
|
|
handleMessage respVar (IncomingResponse resp) = do |
|
|
|
log Debug "Broker.Client" $ TL.toStrict $ [t|Incoming message: %?|] resp |
|
|
|
log Debug "Broker.Client" $ TL.toStrict $ [t|Incoming message: %?|] resp |
|
|
|
(req, respVar, _) <- takeMVar respVar |
|
|
|
(req, respVar, _) <- takeMVar respVar |
|
|
|
|
|
|
|
log Debug "Broker.Client" $ TL.toStrict $ [t|Pending request: %?|] req |
|
|
|
if getRequestId req == getResponseRequestId resp |
|
|
|
if getRequestId req == getResponseRequestId resp |
|
|
|
then putMVar respVar resp |
|
|
|
then putMVar respVar resp |
|
|
|
else log Warning "Broker.Client" $ TL.toStrict $ [t|Request ID mismatch: %?/%?|] (getRequestId req) (getResponseRequestId resp) |
|
|
|
else log Warning "Broker.Client" $ TL.toStrict $ [t|Request ID mismatch: %?/%?|] (getRequestId req) (getResponseRequestId resp) |
|
|
|
|