Expand description
Wrappers around RabbitMQ connection to indefinitely (after the first successful connection) consume, or publish without any errors. If the connection disconnects, the consumer and publisher will wait until the connection is established back again.
Modulesยง
- Helper to auto ack deliveries
- Helper to create a connection and keep it connected.
- Configuration for the rabbitmq connection.
- A stream wrapper for rabbitmq consumer. This stream never fails and will consume until stopped being used.
- Sink wrapper for rabbit publisher.