pma
Hello!
I’m experimenting with GenStage as an abstraction to consume/publish data from/to RabbitMQ.
An initial working version here ( GitHub - pma/wabbit: GenStage based interface for RabbitMQ · GitHub ) and any suggestions to improve the API would be appreciated.
The documentation is still lacking but the example included will hopefully be enough to get started.
The progress so far includes:
- GenStage based generic module to expose a RabbitMQ publisher as a GenStage consumer.
- GenStage based generic module to expose a RabbitMQ consumer as a GenStage producer.
- Automatic reconnects
- Async publish/confirms with a configurable window
- In-memory queue to store messages between reconnects
- Auto retry publishing any unconfirmed/queued messages on reconnect
- Callback for payload encoding/decoding and to override default publish options, per message
- Callback after (re)opening a channel to setup exchanges, queues, bindings
Thank you,
Paulo
Where Next?
Trending in Discussions
Other Trending Topics
Latest on Elixir Forum
Sponsor Spotlight
Master modern tools, write cleaner code, and tackle real-world challenges with Manning books, videos, and courses. Start building today.
Categories:
Sub Categories:
Forums
Popular Tags
- #ecto
- #liveview
- #troubleshooting
- #learning-elixir
- #library
- #deployment
- #erlang
- #testing
- #genserver
- #mix
- #absinthe
- #remote-other
- #otp
- #plug
- #how-to-question
- #macros
- #postgres
- #elixirconf
- #channels
- #exunit
- #discussion
- #code-sync
- #podcasts
- #javascript
- #onsite
- #dialyzer
- #docker
- #authentication
- #umbrella
- #full-time-contract
- #podcasts-by-brainlid
- #ecto-query
- #ai
- #elixirconf-us
- #blog-post
- #elixir-ls
- #phoenix_html
- #iex
- #graphql
- #genstage
- #websockets
- #supervisor
- #advent-of-code
- #distillery
- #processes
- #api
- #forms
- #elixirconf-eu
- #metaprogramming
- #hex
Our Sponsors
Build Elixir applications with speed and confidence.
Supporting innovation across the BEAM ecosystem.
We build reliable cloud platforms for business-critical systems.
Catch errors, track performance, monitor hosts and more.
Error tracking, logs, uptime, and Just Enough APM. Built for developers.
Bringing learning, work and compliance together since 1987.
**Building the future of software with AI, trust, and human connection.**
The deployment platform built for Elixir: PaaS ease, VPS control.
The team behind Membrane, Popcorn, LiveDebugger. Available for hire.
Courses that'll move you from confusion to "Aha, now I get it!"
Showing Posts 1 to 2- Show Best Posts
- Show All (oldest first)
- Show All (newest first)
collegeimprovements
This is very exciting. Currently I’m planning to use Wabit in production? Is it safe to do so?
pma
It’s safe in the sense that it’s provided free of charge, with no restrictions on how it’s used and without warranty of any kind
But that said, I’m currently replacing the amqp lib for this one in some less critical parts of a production system.