Struct PubCommand

pub struct PubCommand {
    pub subject: String,
    pub reply_to: Option<String>,
    pub payload: Bytes,
}

The PUB message publishes the message payload to the given subject name, optionally supplying a reply subject. If a reply subject is supplied, it will be delivered to eligible subscribers along with the supplied payload. Note that the payload itself is optional.

Fields

subject: String

The destination subject to publish to

reply_to: Option<String>

The optional reply inbox subject that subscribers can use to send a response back to the publisher/requestor

payload: Bytes

The message payload data

Implementations

impl PubCommand

pub fn builder() -> PubCommandBuilder

pub fn generate_reply_to() -> String

Generates a random reply_to String

Trait Implementations

impl Clone for PubCommand

fn clone(&self) -> PubCommand

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Command for PubCommand

const CMD_NAME: &'static [u8] = b"PUB"

Command name as a static byte slice

fn into_vec(self) -> Result<Bytes, CommandError>

Encodes the command into bytes

fn try_parse(buf: &[u8]) -> Result<Self, CommandError>

Tries to parse a buffer into a command

impl Debug for PubCommand

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

Formats the value using the given formatter.

impl PartialEq for PubCommand

fn eq(&self, other: &PubCommand) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for PubCommand