A simple streamly wrapper for amqp.

A simple streamly wrapper for amqp. Provides two functions produce and consume.

amqp-streamly

A simple wrapper around amqp.

Usage

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