Struct ReliableQueue 

pub struct ReliableQueue { /* private fields */ }

Reliable message delivery with acknowledgment tracking.

Tracks pending deliveries by correlation ID. On ack timeout, retries with exponential backoff. After max_retries, routes to the dead letter queue.

Implementations

impl ReliableQueue

pub fn new( config: ReliableConfig, dead_letter: Arc<DeadLetterQueue>, ) -> ReliableQueue

Create a new reliable queue with the given config and dead letter queue.

pub fn with_defaults(dead_letter: Arc<DeadLetterQueue>) -> ReliableQueue

Create with default configuration.

pub fn config(&self) -> &ReliableConfig

Get the configuration.

pub fn register(&self, msg: KernelMessage) -> (String, KernelMessage)

Register a message for reliable delivery tracking.

The message must have a correlation_id set. If not, one is generated. Returns the correlation ID used for tracking.

pub fn acknowledge(&self, correlation_id: &str) -> Option<DeliveryResult>

Acknowledge receipt of a message by correlation ID.

Returns Some(DeliveryResult::Acknowledged) if the message was pending, or None if not found (already acked or expired).

pub fn check_timeouts(&self) -> Vec<(String, KernelMessage)>

Check for timed-out deliveries and return messages needing retry.

Returns a list of (correlation_id, message) pairs that have exceeded their ack deadline and should be retried.

pub fn expire_max_retries(&self) -> Vec<DeliveryResult>

Move deliveries that have exceeded max retries to the dead letter queue.

Returns the list of message IDs that were dead-lettered.

pub fn pending_count(&self) -> usize

Number of currently pending deliveries.

pub fn is_pending(&self, correlation_id: &str) -> bool

Check if a specific correlation ID is pending.

pub fn pending_snapshot(&self) -> Vec<(String, PendingDelivery)>

Get a snapshot of all pending deliveries.

pub fn cancel(&self, correlation_id: &str) -> Option<KernelMessage>

Cancel tracking for a specific message.

pub fn timeout_for_attempt(&self, attempt: u32) -> Duration

Calculate the timeout for a given attempt number.