Network.AMQP.Streamly

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

Informations to be sent

See Network.AMQP.publishMsg' for options

Constructors

SendInstructions

Fields

• exchange :: Text
• routingKey :: Text
• mandatory :: Bool
• message :: Message

Instances

Show SendInstructions

Defined in Network.AMQP.Streamly

Methods

showsPrec :: Int -> SendInstructions -> ShowS

show :: SendInstructions -> String

showList :: [SendInstructions] -> ShowS

produce :: (IsStream t, MonadAsync m) => Channel -> t m SendInstructions -> t m ()

Publish the produced messages

consume :: (IsStream t, MonadAsync m) => Channel -> Queue -> Ack -> t m (Message, Envelope)

Stream messages from a queue

See Network.AMQP.consumeMsgs for options