amqp-0.22.2: Client library for AMQP servers (currently only RabbitMQ)
Safe HaskellSafe-Inferred
LanguageHaskell2010

Network.AMQP.Lifted

Synopsis

Documentation

consumeMsgs Source #

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' Source #

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.