Struct async_nats::Message

pub struct Message {
    pub subject: String,
    pub reply: Option<String>,
    pub data: Vec<u8>,
    pub headers: Option<Headers>,
    // some fields omitted
}

A message received on a subject.

Fields

subject: String

The subject this message came from.

reply: Option<String>

Optional reply subject that may be used for sending a response to this message.

data: Vec<u8>

The message contents.

headers: Option<Headers>

Optional headers associated with this Message.

Implementations

impl Message

pub async fn respond(&self, msg: impl AsRef<[u8]>) -> Result<()>

Respond to a request message.

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<(), Error>

Formats the value using the given formatter.