Struct OutboxMessage 

pub struct OutboxMessage {

    pub message_id: OutboxMessageId,
    pub stream_id: StreamId,
    pub process_id: ProcessId,
    pub tenant_id: TenantId,
    pub correlation_id: CorrelationId,
    pub conversation_id: ConversationId,
    pub causation_event_id: EventId,
    pub message_type: Box<str>,
    pub recipient: Box<str>,
    pub payload: Value,
    pub payload_schema: Option<Box<str>>,
    pub created_at: OffsetDateTime,
    pub deliver_after: Option<OffsetDateTime>,
    pub attempt_count: u32,
}

An outbound message queued for delivery via AS4 or another channel.

The message carries both routing information (recipient, message_type) and full correlation metadata so the delivery worker can trace every send back to the domain event that caused it.

Construct with OutboxMessage::new and optionally chain OutboxMessage::with_deliver_after for deferred delivery.

Fields

message_id: OutboxMessageId

Stable unique identifier for this outbox entry.

stream_id: StreamId

The process stream that produced this outbound message.

process_id: ProcessId

The MaKo process instance.

tenant_id: TenantId

The tenant sending this message.

correlation_id: CorrelationId

Propagated correlation root from the triggering event.

conversation_id: ConversationId

Business conversation this message belongs to (e.g. UTILMD ↔ APERAK).

causation_event_id: EventId

The persisted event that directly caused this outbound message.

message_type: Box<str>

EDIFACT or XML message type (e.g. "APERAK", "CONTRL", "UTILMD").

recipient: Box<str>

GLN or EIC code of the intended recipient market participant.

payload: Value

Serialized message payload.

Typically a JSON-encoded string of EDIFACT bytes or a structured JSON object for non-EDIFACT channels.

payload_schema: Option<Box<str>>

BO4E JSON Schema URL that validates payload, if present.

None for raw EDIFACT or untyped payloads. Set by domain workflows via PendingOutbox::with_schema when the payload is a BO4E object.

created_at: OffsetDateTime

When this entry was created.

deliver_after: Option<OffsetDateTime>

Do not deliver before this time.

None means deliver immediately (as soon as the delivery worker runs).

attempt_count: u32

Number of delivery attempts so far. Starts at 0, incremented by OutboxStore::reschedule.

Implementations

impl OutboxMessage

pub fn new( stream_id: StreamId, process_id: ProcessId, tenant_id: TenantId, correlation_id: CorrelationId, conversation_id: ConversationId, causation_event_id: EventId, message_type: impl Into<Box<str>>, recipient: impl Into<Box<str>>, payload: Value, ) -> Self

Construct a new outbox message.

message_id and created_at are generated automatically. attempt_count is initialized to 0.

Call OutboxMessage::with_deliver_after to schedule deferred delivery.

pub fn with_deliver_after(self, deliver_after: OffsetDateTime) -> Self

Set a deferred delivery time.

The message will not appear in OutboxStore::pending results until now >= deliver_after.

Trait Implementations

impl Clone for OutboxMessage

fn clone(&self) -> OutboxMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OutboxMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OutboxMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for OutboxMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.