Struct MqttMessage 

pub struct MqttMessage {
    pub topic: String,
    pub payload: Vec<u8>,
    pub qos: QoS,
    pub retain: bool,
    pub client_id: Option<String>,
    pub timestamp: i64,
}

Fields

topic: String

payload: Vec<u8>

qos: QoS

retain: bool

client_id: Option<String>

timestamp: i64

Implementations

impl MqttMessage

pub fn new(topic: impl Into<String>, payload: Vec<u8>) -> MqttMessage

pub fn with_qos(self, qos: QoS) -> MqttMessage

pub fn retain(self) -> MqttMessage

pub fn with_client(self, client_id: impl Into<String>) -> MqttMessage

pub fn text(&self) -> Option<&str>

pub fn json<T>(&self) -> Option<T>

where T: DeserializeOwned,

impl MqttMessage

pub fn text_message( topic: impl Into<String>, text: impl Into<String>, ) -> MqttMessage

pub fn json_message<T>( topic: impl Into<String>, data: &T, ) -> Result<MqttMessage, MqttError>

where T: Serialize,

Trait Implementations

impl Clone for MqttMessage

fn clone(&self) -> MqttMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MqttMessage

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

Formats the value using the given formatter.