Struct async_nats::message::Message

pub struct Message {
    pub subject: String,
    pub reply: Option<String>,
    pub payload: Bytes,
    pub headers: Option<HeaderMap>,
    pub status: Option<StatusCode>,
    pub description: Option<String>,
    pub length: usize,
}

A Core NATS message.

Fields

subject: String

Subject to which message is published to.

reply: Option<String>

Optional reply subject to which response can be published by crate::Subscriber. Used for request-response pattern with crate::Client::request.

payload: Bytes

Payload of the message. Can be any arbitrary data format.

headers: Option<HeaderMap>

Optional headers. Rust client uses http::header.

status: Option<StatusCode>

Optional Status of the message. Used mostly for internal handling.

description: Option<String>

Optional status description.

length: usize

Trait Implementations

impl Debug for Message

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

Formats the value using the given formatter.

impl From<Message> for Message

fn from(source: Message) -> Message

Converts to this type from the input type.

impl TryFrom<RawMessage> for Message

type Error = Box<dyn Error + Send + Sync + 'static, Global>

The type returned in the event of a conversion error.

fn try_from(value: RawMessage) -> Result<Self, Self::Error>

Performs the conversion.