Struct DeadLetterQueue 

pub struct DeadLetterQueue {
    letters: VecDeque<DeadLetter>,
    config: DlqConfig,
    next_sequence: u64,
    total_received: u64,
    total_replayed: u64,
    total_expired: u64,
}

Dead letter queue.

Fields

letters: VecDeque<DeadLetter>

config: DlqConfig

next_sequence: u64

total_received: u64

total_replayed: u64

total_expired: u64

Implementations

impl DeadLetterQueue

pub fn new(config: DlqConfig) -> DeadLetterQueue

Create a new DLQ with the given configuration.

pub fn enqueue( &mut self, envelope: MessageEnvelope, reason: DeadLetterReason, destination: KernelId, attempts: u32, )

Route a message to the DLQ.

pub fn replay<F>(&mut self, filter: F) -> Vec<DeadLetter>

where F: Fn(&DeadLetter) -> bool,

Replay messages from the DLQ matching a filter.

Returns messages removed from the DLQ for re-delivery.

pub fn replay_for(&mut self, destination: &KernelId) -> Vec<DeadLetter>

Replay all messages destined for a specific actor.

pub fn expire_old(&mut self) -> u64

Expire messages older than max_age.

pub fn browse(&self, limit: usize) -> Vec<&DeadLetter>

Browse the DLQ contents (non-destructive).

pub fn len(&self) -> usize

Number of messages in the DLQ.

pub fn is_empty(&self) -> bool

Check if empty.

pub fn clear(&mut self)

Clear the DLQ.

pub fn metrics(&self) -> DlqMetrics

Get DLQ metrics.

pub fn config(&self) -> &DlqConfig

Get the DLQ configuration.