Struct DeadLetterRecord 

pub struct DeadLetterRecord {

    pub queue: String,
    pub job_id: String,
    pub job_type: String,
    pub payload: Option<Payload>,
    pub priority: Priority,
    pub max_attempts: u32,
    pub custom: HashMap<String, Primitive>,
    pub trace_context: Option<TraceContext>,
    pub enqueued_at: SystemTime,
    pub scheduled_at: Option<SystemTime>,
    pub cause: DeadLetterCause,
    pub failed_at: SystemTime,
    pub final_attempt: u32,
    pub last_reason: Option<String>,
}

A dead-lettered job retained by the server, returned by drain_dead_letters.

It is a snapshot for inspection and manual replay: read cause, last_reason, and final_attempt to see what went wrong, then call to_enqueue_request to re-submit it.

Fields

queue: String

The queue the job belonged to.

job_id: String

The dead-lettered job’s server-assigned id.

job_type: String

The producer’s job-type tag.

payload: Option<Payload>

The job’s payload, if any.

priority: Priority

The job’s effective priority.

max_attempts: u32

The maximum delivery attempts the job died with (the producer’s override, or the queue default the server applied).

custom: HashMap<String, Primitive>

Custom metadata the producer attached.

trace_context: Option<TraceContext>

The producer’s trace context, if any and well-formed.

enqueued_at: SystemTime

When the producer originally enqueued the job.

scheduled_at: Option<SystemTime>

When the producer scheduled the job to run, if it was delayed; None for a job that was available immediately.

cause: DeadLetterCause

Why the job was dead-lettered.

failed_at: SystemTime

When the job was dead-lettered.

final_attempt: u32

The attempt the job died on (1-based).

last_reason: Option<String>

The reason from the last nack, when the job died on a nack path; None for a lease-expiry death.

Implementations

impl DeadLetterRecord

pub fn to_enqueue_request(&self) -> EnqueueRequest

Builds an EnqueueRequest that replays this job into its original queue, preserving its payload, priority, max attempts, custom metadata, and trace context. The replay is a fresh job — the server assigns a new id and resets the attempt counter — and it runs immediately: the original scheduled_at is deliberately not copied, since it is in the past by the time a job has died and been drained.

Equivalent to EnqueueRequest::from(&record); both leave the record intact. To consume the record without cloning, use EnqueueRequest::from(record) (or record.into()).

Trait Implementations

impl Clone for DeadLetterRecord

fn clone(&self) -> DeadLetterRecord

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DeadLetterRecord

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

Formats the value using the given formatter.

impl From<&DeadLetterRecord> for EnqueueRequest

fn from(r: &DeadLetterRecord) -> Self

Replays a dead-lettered job into its original queue, leaving the record intact.

impl From<DeadLetterRecord> for EnqueueRequest

fn from(r: DeadLetterRecord) -> Self

Replays a dead-lettered job into its original queue, consuming the record.