amqp-streamly: A simple streamly wrapper for amqp

[ amqp, bsd3, conduit, library, rabbitmq, streamly ] [ Propose Tags ]

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


[Skip to Readme]

Modules

[Index] [Quick Jump]

Downloads

Maintainer's Corner

Package maintainers

For package maintainers and hackage trustees

Candidates

Versions [RSS] 0.1.0, 0.2.0, 0.2.1, 0.3.0
Change log ChangeLog.md
Dependencies amqp (>=0.22.2 && <0.23), base (>=4.7 && <5), streamly (>=0.9 && <0.11), streamly-core (>=0.2.0 && <0.3), text (>=1.2.4.0 && <3) [details]
License BSD-3-Clause
Copyright Gautier DI FOLCO
Author Gautier DI FOLCO
Maintainer gautier.difolco@gmail.com
Category streamly, conduit, amqp, rabbitmq
Home page https://github.com/blackheaven/amqp-streamly#readme
Bug tracker https://github.com/blackheaven/amqp-streamly/issues
Source repo head: git clone https://github.com/blackheaven/amqp-streamly
Uploaded by gdifolco at 2024-04-14T10:44:09Z
Distributions
Downloads 469 total (22 in the last 30 days)
Rating (no votes yet) [estimated by Bayesian average]
Your Rating
  • λ
  • λ
  • λ
Status Docs available [build log]
Last success reported on 2024-04-14 [all 1 reports]

Readme for amqp-streamly-0.3.0

[back to package description]

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