Struct Msg 

pub struct Msg {
    pub subject: String,
    pub payload: Bytes,
    pub headers: HashMap<String, String>,
    pub ack: AckHandle,
}

Re-exports every public item from klieo-core. One message delivered to a subscriber.

Fields

subject: String

Subject the message was published on.

payload: Bytes

Payload bytes.

headers: HashMap<String, String>

Headers.

ack: AckHandle

Acknowledgement handle. The impl provides the underlying mechanism; callers must invoke exactly one of ack / nak / term per message or rely on visibility-timeout redelivery.

Trait Implementations

impl Debug for Msg

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

Formats the value using the given formatter.