You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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
declareQueue
consumeMsgs
Some programs are multi-threaded. It should perhaps be pointed out that while this works fine:
forkIO $
openConnection
openChannel
declareQueue
consumeMsgs
and this works fine:
openConnection
forkIO $
openChannel
declareQueue
consumeMsgs
this just silently fails (no errors, just does not work):
openConnection
openChannel
forkIO $
declareQueue
consumeMsgs
The reason being, I suppose, that each channel gets its own thread by the amqp library. However, this consequence of the separate channel threads is not obvious from the documentation.
On a side note, after addConnectionClosedHandler was added in v0.2.7 and
qos in v0.4.0, it is now possible to make quite solid AMQP clients with this library.
The text was updated successfully, but these errors were encountered:
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
declareQueue
consumeMsgs
Some programs are multi-threaded. It should perhaps be pointed out that while this works fine:
forkIO $
openConnection
openChannel
declareQueue
consumeMsgs
and this works fine:
openConnection
forkIO $
openChannel
declareQueue
consumeMsgs
this just silently fails (no errors, just does not work):
openConnection
openChannel
forkIO $
declareQueue
consumeMsgs
The reason being, I suppose, that each channel gets its own thread by the amqp library. However, this consequence of the separate channel threads is not obvious from the documentation.
On a side note, after addConnectionClosedHandler was added in v0.2.7 and
qos in v0.4.0, it is now possible to make quite solid AMQP clients with this library.
The text was updated successfully, but these errors were encountered: