Struct MessageMetadata 

pub struct MessageMetadata {
    pub message_id: String,
    pub retry_attempt: u32,
    pub max_retries: u32,
    pub created_at: DateTime<Utc>,
    pub last_processed_at: DateTime<Utc>,
    pub error_history: Vec<ErrorRecord>,
    pub headers: HashMap<String, String>,
    pub source: MessageSource,
}

Metadata associated with a message

Fields

message_id: String

Unique message ID for tracking

retry_attempt: u32

Current retry attempt (0 = first attempt, 1 = first retry, etc.)

max_retries: u32

Maximum number of retry attempts allowed

created_at: DateTime<Utc>

When the message was first created

last_processed_at: DateTime<Utc>

When the message was last processed (updated on each retry)

error_history: Vec<ErrorRecord>

History of errors from previous attempts

headers: HashMap<String, String>

Custom headers for additional metadata

source: MessageSource

Source information (queue, exchange, routing key where message originated)

Trait Implementations

impl Clone for MessageMetadata

fn clone(&self) -> MessageMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageMetadata

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MessageMetadata

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MessageMetadata

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

where __S: Serializer,

Serialize this value into the given Serde serializer.