amqp
amqp copied to clipboard
hreinhardt
Haskell AMQP client library
We are using the addConnectionBlockedHandler to log a message when rabbit when connections are blocked due to resource constraints but do not see any output when we see connections are...
https://github.com/hreinhardt/amqp/blob/3ddd97222881a2d2af9e2d23bdcfd63f507c0b09/Network/AMQP/Internal.hs#L418-L431 `closeConnection` swallows any IO exceptions it might encounter upon sending the close connection message to the server, and then waits on the server indefinitely, expecting the server to send...
I noticed that if multiple connections to the same amqp server are opened on separate threads, one thread calling `closeConnection` causes all of the connections to stop working. I don't...
Thanx again for your AMQP library! Here is something I added to my client which you might find useful: ``` type FieldEntry = (Text, FieldValue) toFieldEntry ∷ ToFieldValue a ⇒...
In my app, by mistake, I did manually `ackEnv` a message received by a channel in the `NoAck` mode. The application did not crash, but the query consumer was silently...
Either getting `publishMsg` to return it or via a new wrapping method as it would be a breaking change to the API. Not being able to match the outgoing message...
I'm sorry for raising this as an issue, perhaps the maintainer would prefer an email for future issues such as this? A common minimum initial call sequence is openConnection openChannel...
When I upgrade my code from 0.4.2 to 0.5 I get the following mysterious error when connecting to a message queue: ``` Data.Binary.Get.runGet at position 0: demandInput: not enough bytes...
