Work with AMQP reliably, especially in times of cluster membership changes.
Switch branches/tags
Nothing to show
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
config
lib/test_durable_queue
test
.formatter.exs
.gitignore
README.md
mix.exs
mix.lock

README.md

TestDurableQueue

Example of cleanly auto-reconnect durable queue to RabbitMQ, especially in times of cluster membership changes.

Checkout my blog!

Features

  • Reuse connection: no reconnect (recreation of Connection) unless the connected node (on AMQP side) fails
  • Exactly one channel, and resilent to queue failure (queue down due to RabbitMQ cluster changes)
  • Useful logging (with lager because it's bundled with amqp_client)
  • Example of passing in options through Supervisor layers