Struct 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 that has been published to a NATS Subject.

Fields

subject: String

The NATS Subject that this Message has been published to.

reply: Option<String>

The optional reply Subject that may be used for sending responses when using the request/reply pattern.

data: Vec<u8>

The Message contents.

headers: Option<Headers>

Optional headers associated with this Message.

Implementations

impl Message

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

Respond to a request message.

Example

nc.subscribe("help.request")?.with_handler(move |m| {
    m.respond("ans=42")?; Ok(())
});

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 Display for Message

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

Formats the value using the given formatter.