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ยง
- auto_
ack - Helper to auto ack deliveries
- comms
- Helper to create a connection and keep it connected.
- config
- Configuration for the rabbitmq connection.
- consumer
- A stream wrapper for rabbitmq consumer. This stream never fails and will consume until stopped being used.
- exchanges
- publish_
properties - publisher
- Sink wrapper for rabbit publisher.
- stream_
builder