Struct Message 

pub struct Message {
    pub command: BaseCommand,
    pub payload: Option<Payload>,
}

Pulsar binary message

this structure holds any command sent to pulsar, like looking up a topic or subscribing on a topic

Fields

command: BaseCommand

Basic pulsar command, as defined in Pulsar’s protobuf file

payload: Option<Payload>

payload for topic messages

Implementations

impl Message

pub fn request_key(&self) -> Option<RequestKey>

returns the message’s RequestKey if present

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate 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 Encoder<Message> for Codec

Available on crate feature tokio-runtime only.

type Error = ConnectionError

The type of encoding errors.

fn encode( &mut self, item: Message, dst: &mut BytesMut, ) -> Result<(), ConnectionError>

Encodes a frame into the buffer provided.