Skip to content

blackheaven/amqp-streamly

Repository files navigation

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

About

A simple streamly wrapper for amqp

Resources

License

Stars

Watchers

Forks

Packages

No packages published