Module queue 

Re-exports

pub use crate::queue::channel::Channel;

pub use compensation::Compensator;

pub use compensation::Identifiable;

pub use manager::QueueManager;

Modules

batcher

channel

compensation

compression

manager

Structs

Message

Represents a message received from the queue. The user MUST call ack() to acknowledge successful processing.

NackPolicy

QueuedItem

A wrapper for items that might require acknowledgement

Enums

AckAction

Action to take on a message: Acknowledge or Negative Acknowledge (Fail)

NackDisposition

Constants

HEADER_ATTEMPT

HEADER_CREATED_AT

HEADER_NACK_REASON

Traits

MqBackend

Functions

decide_nack

Type Aliases

AckFn

NackFn