Struct async_nats::message::Message

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

A Core NATS message.

Fields

subject: Subject

Subject to which message is published to.

reply: Option<Subject>

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.

status: Option<StatusCode>

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

description: Option<String>

Optional status description.

length: usize

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a copy 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<Message> for Message

fn from(source: Message) -> Message

Converts to this type from the input type.

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.

impl TryFrom<Message> for StreamMessage

type Error = Error<StreamMessageErrorKind>

The type returned in the event of a conversion error.

fn try_from(message: Message) -> Result<Self, Self::Error>

Performs the conversion.