Struct DeadLetterQueueBackend 

pub struct DeadLetterQueueBackend { /* private fields */ }

A backend wrapper that forwards failed messages to a dead letter queue.

This wraps an existing MessageBackend and provides methods to send messages with failure context to a dedicated DLQ queue/exchange.

Implementations

impl DeadLetterQueueBackend

pub fn new(backend: Arc<dyn MessageBackend>, dlq_name: &str) -> Self

Create a new DLQ backend wrapper.

Arguments

• backend - The backend to use for sending DLQ messages (e.g., RabbitMQ DLQ queue)
• dlq_name - Name identifier for this DLQ (used in logs/metrics)

pub async fn send_to_dlq( &self, dlq_message: &DeadLetterMessage, ) -> WorkerResult<()>

Send a message to the dead letter queue with failure context.

This method serializes the DLQ message and sends it to the configured backend (e.g., RabbitMQ DLQ queue, Redis stream, etc.).

Arguments

• dlq_message - The dead letter message containing original payload and failure info

Returns

Ok if successfully sent to DLQ, Err if DLQ operation failed

pub fn dlq_name(&self) -> &str

Get the DLQ name.

pub fn backend(&self) -> &Arc<dyn MessageBackend>

Get a reference to the underlying backend.

Trait Implementations

impl Debug for DeadLetterQueueBackend

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.