Struct tapa_cgloop_nats::NatsMessage

pub struct NatsMessage {
    pub subject: String,
    pub reply: Option<String>,
    pub data: Vec<u8, Global>,
    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, Global>

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

Respond to a request message.

Trait Implementations

impl Clone for Message

pub 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

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

Formats the value using the given formatter.

impl From<Message> for Message

pub fn from(sync: Message) -> Message

Performs the conversion.