A simple wrapper around amqp.
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