Struct QueuedMessage 

pub struct QueuedMessage {

    pub id: i64,
    pub sender: String,
    pub recipient: String,
    pub domain: String,
    pub message_data: Vec<u8>,
    pub status: QueueStatus,
    pub attempts: u32,
    pub max_attempts: u32,
    pub next_retry: i64,
    pub last_error: Option<String>,
    pub message_id: Option<String>,
    pub created_at: i64,
    pub updated_at: i64,
    pub is_forwarded: bool,
}

One queued outbound message — the full row stored in the outbound queue.

Fields

id: i64

Store-native primary key.

sender: String

Envelope sender (reverse path).

recipient: String

Envelope recipient (single forward path; multi-recipient messages fan out into one row per recipient).

domain: String

Recipient’s domain — extracted for MX-grouped batching.

message_data: Vec<u8>

Full RFC 5322 message body (including headers).

status: QueueStatus

Current lifecycle status.

attempts: u32

Number of delivery attempts made so far.

max_attempts: u32

Cap after which Failed flips to Bounced.

next_retry: i64

Epoch seconds — the earliest time the next attempt is eligible.

last_error: Option<String>

Last error response from the remote MX, if any.

message_id: Option<String>

Message-ID: header value, for log correlation.

created_at: i64

Epoch seconds when the row was first enqueued.

updated_at: i64

Epoch seconds of the most recent update.

is_forwarded: bool

true when the message came from a forwarding rule rather than a local sender.

Trait Implementations

impl Clone for QueuedMessage

fn clone(&self) -> QueuedMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueuedMessage

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

Formats the value using the given formatter.