Struct DeadLetterMessage 

pub struct DeadLetterMessage {
    pub original_id: String,
    pub original_payload: Value,
    pub source_queue: String,
    pub attempt_count: u32,
    pub error_message: String,
    pub dlq_timestamp: DateTime<Utc>,
    pub last_worker_id: Option<String>,
    pub failure_context: Value,
}

Represents a message that has been sent to the Dead Letter Queue. Contains the original message payload along with failure context.

Fields

original_id: String

Original message ID

original_payload: Value

Original message payload

source_queue: String

Queue where the message originated

attempt_count: u32

Number of processing attempts before DLQ

error_message: String

Error that caused the final failure

dlq_timestamp: DateTime<Utc>

Timestamp when message was sent to DLQ

last_worker_id: Option<String>

Worker ID that processed the message last

failure_context: Value

Additional metadata about the failure

Implementations

impl DeadLetterMessage

pub fn new( original_id: String, original_payload: Value, source_queue: String, attempt_count: u32, error_message: String, ) -> Self

Create a new dead letter message from processing context.

pub fn with_worker_id(self, worker_id: String) -> Self

Set the worker ID that last processed this message.

pub fn with_context(self, key: &str, value: Value) -> Self

Add additional failure context metadata.

pub fn to_json(&self) -> Result<String, Error>

Convert to JSON string for storage/transmission.

pub fn from_json(json: &str) -> Result<Self, Error>

Parse from JSON string.

Trait Implementations

impl Clone for DeadLetterMessage

fn clone(&self) -> DeadLetterMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DeadLetterMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DeadLetterMessage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for DeadLetterMessage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.