amqp-streamly-0.3.0: A simple streamly wrapper for amqp
Safe HaskellSafe-Inferred
LanguageHaskell2010

Network.AMQP.Streamly

Synopsis

How to use this library

This section contains basic step-by-step usage of the library.

You can either build a producer, which will publish all the messages of a stream:

Streamly.drain $ produce channel sendInstructionsStream

Or a consumer, which will contain the Messages and Envelopes of a queue:

Streamly.drain $ consume channel aQueue NoAck

data SendInstructions Source #

Informations to be sent

See Network.AMQP.publishMsg' for options

Instances

Instances details
Show SendInstructions Source # 
Instance details

Defined in Network.AMQP.Streamly

produce :: MonadIO m => Channel -> Stream m SendInstructions -> Stream m () Source #

Publish the produced messages

consume :: MonadIO m => Channel -> Queue -> Ack -> Stream m (Message, Envelope) Source #

Stream messages from a queue

See Network.AMQP.consumeMsgs for options