Struct Message 

pub struct Message {
    pub id: Option<String>,
    pub name: String,
    pub kind: MessageKind,
    pub payload: Vec<u8>,
    pub content_type: String,
    pub metadata: Vec<(String, String)>,
}

Serializable transport message used by handlers.

Fields

id: Option<String>

name: String

kind: MessageKind

payload: Vec<u8>

content_type: String

metadata: Vec<(String, String)>

Implementations

impl Message

pub fn new(name: impl Into<String>, kind: MessageKind, payload: Vec<u8>) -> Self

Create a transport message.

pub fn with_id(self, id: impl Into<String>) -> Self

Add a durable message id.

pub fn with_metadata( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Add metadata.

pub fn id(&self) -> Option<&str>

Get the durable message id, if this message has one.

pub fn name(&self) -> &str

Get the message name.

The name flows unmodified into broker routing primitives (NATS subject suffix, Kafka topic, RabbitMQ routing/binding key). A . is a routing segment separator on topic transports, so it changes routing granularity rather than being an opaque label — see validate_message_name.

pub fn validate_name(&self) -> Result<(), MessageNameError>

Validate this message’s name for use as a transport routing identifier.

Delegates to validate_message_name: rejects empty, over-long, control-character-bearing, or wildcard-bearing (*/#/>) names. Publish boundaries call this before a name becomes a subject/topic/routing key; the inbound Knative ingress calls it on the ce-type it reads off the wire.

pub fn payload(&self) -> &[u8]

Get the raw payload bytes.

pub fn metadata(&self, key: &str) -> Option<&str>

Get a metadata value by key.

pub fn correlation_id(&self) -> Option<&str>

Get the correlation id, if present.

pub fn causation_id(&self) -> Option<&str>

Get the causation id, if present.

pub fn payload_json<T: DeserializeOwned>(&self) -> Result<T, PayloadDecodeError>

Decode the raw payload as JSON.

pub fn payload_bitcode<T: DeserializeOwned>( &self, ) -> Result<T, PayloadDecodeError>

Decode the raw payload as bitcode.

Security caveat: bitcode is a compact binary format that is not hardened against hostile input. Only decode bitcode from trusted producers — do not use it for payloads arriving on a public bus or other untrusted ingress, where a malformed/adversarial buffer could trigger excessive allocation or a panic. Prefer payload_json for untrusted input.

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Message

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<&OutboxMessage> for Message

fn from(outbox: &OutboxMessage) -> Self

Map a durable outbox row to a canonical transport message.

• id ← outbox message id (the stable durable id);
• name ← event_type;
• kind ← Command when a point-to-point destination is set, else Event;
• payload ← raw codec bytes, content_type = application/octet-stream;
• metadata ← the outbox metadata (correlation/causation/trace/auth) plus framework-derived keys under the reserved SOURCED_METADATA_PREFIX namespace (payload codec, destination, source-aggregate context) so decode/routing context can never be shadowed by a user metadata key.

impl Serialize for Message

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

where __S: Serializer,

Serialize this value into the given Serde serializer.