Struct MessageEnvelope 

pub struct MessageEnvelope<T> {
    pub payload: T,
    pub metadata: MessageMetadata,
}

Message envelope that wraps the actual payload with metadata

Fields

payload: T

The actual message payload

metadata: MessageMetadata

Message metadata

Implementations

impl<T> MessageEnvelope<T>

pub fn new(payload: T, source_queue: &str) -> Self

Create a new message envelope with the given payload

pub fn with_source( payload: T, queue: &str, exchange: Option<&str>, routing_key: Option<&str>, publisher: Option<&str>, ) -> Self

Create envelope with source details

pub fn with_max_retries(self, max_retries: u32) -> Self

Set the maximum number of retries

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

Add a custom header

pub fn is_retry_exhausted(&self) -> bool

Check if this message has exceeded its retry limit

pub fn is_first_attempt(&self) -> bool

Check if this is the first attempt (not a retry)

pub fn next_retry_attempt(&self) -> u32

Get the next retry attempt number

pub fn with_error( self, error: &str, error_type: ErrorType, context: Option<&str>, ) -> Self

Record an error and create a new envelope for retry

pub fn last_error(&self) -> Option<&ErrorRecord>

Get the last error if any

pub fn errors_by_type(&self, error_type: &ErrorType) -> Vec<&ErrorRecord>

Get all errors of a specific type

pub fn get_failure_summary(&self) -> String

Get a summary string for dead letter analysis

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

where T: Serialize,

Convert to JSON for debugging

Trait Implementations

impl<T: Clone> Clone for MessageEnvelope<T>

fn clone(&self) -> MessageEnvelope<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for MessageEnvelope<T>

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

Formats the value using the given formatter.

impl<'de, T> Deserialize<'de> for MessageEnvelope<T>

where T: Deserialize<'de>,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T> Serialize for MessageEnvelope<T>

where T: Serialize,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.