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;
pub use presence::ConsumerPresence;
pub use presence::ConsumerPresenceRegistry;
pub use presence::PresenceState;
pub use presence::DEFAULT_PRESENCE_TTL_MS;

Modules§

consumer_group
Consumer Groups for Queue
deque
Core Queue / Deque implementation
mode
presence
Queue consumer presence — issue #742.