Skip to main content

Module queue

Module queue 

Source
Expand description

Queue / Deque Storage Module

FIFO/LIFO message queue with:

  • Push/Pop from both ends (deque)
  • Consumer groups with acknowledgment
  • Dead-letter queue support
  • Priority queue mode
  • Per-message TTL

Re-exports§

pub use consumer_group::ConsumerGroup;
pub use consumer_group::PendingEntry;
pub use deque::QueueSide;
pub use deque::QueueStore;
pub use mode::QueueMode;

Modules§

consumer_group
Consumer Groups for Queue
deque
Core Queue / Deque implementation
mode