Struct RawMessage 

pub struct RawMessage { /* private fields */ }

An owned snapshot of a message as it travels through the framework.

RawMessage is what the runtime hands to type-erased handlers and what test clients return from assertions. Broker-specific subscribers usually expose a richer IncomingMessage type that wraps the broker’s native delivery handle.

Implementations

impl RawMessage

pub fn new(name: impl Into<String>, payload: impl Into<Bytes>) -> Self

Constructs a new message for the given name and payload, with no headers.

pub fn with_headers(self, headers: Headers) -> Self

Builder-style setter that replaces the header map.

pub fn name(&self) -> &str

Returns the name / subject this message was published to.

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

Returns the message payload as a byte slice.

pub fn payload_bytes(&self) -> Bytes

Returns a clone of the payload bytes. Cheap because Bytes is reference-counted.

pub fn headers(&self) -> &Headers

Returns a shared reference to the message headers.

pub fn headers_mut(&mut self) -> &mut Headers

Returns a mutable reference to the message headers.

Trait Implementations

impl Clone for RawMessage

fn clone(&self) -> RawMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RawMessage

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

Formats the value using the given formatter.

impl Eq for RawMessage

impl PartialEq for RawMessage

fn eq(&self, other: &RawMessage) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for RawMessage