Expand description
Simplified interface for interacting with queues.
Different queuing systems will provide many different configuration options and features — we do not attempt to provide a unified interface for all of them. Rather, we provided a bare minimum interface that is sufficient to satisfy the semantics of this system. In particular, connection management, queue declaration, queue consumption, and message publishing are the only operations that are supported.
Modules§
- amqp
- AMQP queue binding using
lapin. - in_
memory - An in-memory implementation of
Connectionand its associated types.
Structs§
- Queue
Options - Queue declaration options.
- With
- Publisher for the
PublisherExt::withfunction.
Enums§
- Delivery
Mode - The delivery mode of a message.
- Queue
Durability - The durability of a queue.
- Syndication
Mode - The syndication mode of a queue.
Traits§
- Connection
- A connection to a queue.
- Publisher
- A non-locking replacement for
Sink. - Publisher
Ext - Extension trait for
Publisher. - Queue
Handle - A handle to a queue.