| Safe Haskell | Safe-Inferred |
|---|---|
| Language | Haskell2010 |
Network.AMQP.Lifted
Synopsis
- consumeMsgs :: MonadBaseControl IO m => Channel -> Text -> Ack -> ((Message, Envelope) -> m ()) -> m ConsumerTag
- consumeMsgs' :: MonadBaseControl IO m => Channel -> Text -> Ack -> ((Message, Envelope) -> m ()) -> (ConsumerTag -> m ()) -> FieldTable -> m ConsumerTag
Documentation
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 ((
has access to the captured state, all its side-effects in m are discarded.Message, Envelope) -> m ())
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.