Network.AMQP.Lifted

Documentation

consumeMsgs

Arguments

:: MonadBaseControl IO m

=> Channel

-> Text

Specifies the name of the queue to consume from.

-> Ack

-> ((Message, Envelope) -> m ())

-> m ConsumerTag

Lifted version of consumeMsgs (please look there for documentation).

In addition, while the callback function ((Message, Envelope) -> m ()) has access to the captured state, all its side-effects in m are discarded.

consumeMsgs'

Arguments

:: MonadBaseControl IO m

=> Channel

-> Text

Specifies the name of the queue to consume from.

-> Ack

-> ((Message, Envelope) -> m ())

-> (ConsumerTag -> m ())

-> FieldTable

-> m ConsumerTag

an extended version of consumeMsgs that allows you to define a consumer cancellation callback and include arbitrary arguments.