Struct TransportMessage 

pub struct TransportMessage {
    pub id: MessageId,
    pub payload: Bytes,
    pub metadata: TransportMessageMetadata,
}

A wrapper for a message being sent or received over a transport.

Fields

id: MessageId

The unique identifier of the message.

payload: Bytes

The binary payload of the message.

metadata: TransportMessageMetadata

Metadata associated with the message.

Implementations

impl TransportMessage

pub fn new(id: MessageId, payload: Bytes) -> Self

Creates a new TransportMessage with a given ID and payload.

Example

let msg = TransportMessage::new(MessageId::from(1), Bytes::from("hello"));

pub const fn with_metadata( id: MessageId, payload: Bytes, metadata: TransportMessageMetadata, ) -> Self

Creates a new TransportMessage with the given ID, payload, and metadata.

pub const fn size(&self) -> usize

Returns the size of the message payload in bytes.

pub const fn is_compressed(&self) -> bool

Returns true if the message is compressed.

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

Returns the content type of the message, if specified.

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

Returns the correlation ID of the message, if specified.

Trait Implementations

impl Clone for TransportMessage

fn clone(&self) -> TransportMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TransportMessage

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

Formats the value using the given formatter.