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