Struct actix_mqtt::Publish

pub struct Publish<S> { /* fields omitted */ }

Publish message

Methods

impl<S> Publish<S>

pub fn dup(&self) -> bool

this might be re-delivery of an earlier attempt to send the Packet.

pub fn retain(&self) -> bool

pub fn qos(&self) -> QoS

the level of assurance for delivery of an Application Message.

pub fn publish_topic(&self) -> &str

the information channel to which payload data is published.

pub fn session(&self) -> Ref<S>

returns reference to a connection session

pub fn session_mut(&mut self) -> RefMut<S>

returns mutable reference to a connection session

pub fn id(&self) -> Option<u16>

only present in PUBLISH Packets where the QoS level is 1 or 2.

pub fn topic(&self) -> &Path<String<Bytes>>

pub fn topic_mut(&mut self) -> &mut Path<String<Bytes>>

pub fn query(&self) -> &str

pub fn packet(&self) -> &Publish

pub fn payload(&self) -> &Bytes

the Application Message that is being published.

pub fn take_payload(&self) -> Bytes

Extract Bytes from packet payload

pub fn sink(&self) -> &MqttSink

Mqtt client sink object

pub fn json<T: DeserializeOwned>(&mut self) -> Result<T, JsonError>

Loads and parse application/json encoded body.

Trait Implementations

impl<S> Debug for Publish<S>

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

Formats the value using the given formatter.