Struct rumqtt::client::MqttClient

pub struct MqttClient { /* fields omitted */ }

Handle to send requests and commands to the network eventloop

Methods

impl MqttClient

pub fn start(
    opts: MqttOptions
) -> Result<(Self, Receiver<Notification>), ConnectError>

Starts a new mqtt connection in a thread and returns [mqttclient] instance to send requests/commands to the event loop and a crossbeam channel receiver to receive notifications sent by the event loop.

See select.rs example [mqttclient]: struct.MqttClient.html

pub fn publish<S, V, B>(
    &mut self,
    topic: S,
    qos: QoS,
    retained: B,
    payload: V
) -> Result<(), ClientError> where
    S: Into<String>,
    V: Into<Vec<u8>>,
    B: Into<bool>, 

Requests the eventloop for mqtt publish

pub fn subscribe<S>(&mut self, topic: S, qos: QoS) -> Result<(), ClientError> where
    S: Into<String>, 

Requests the eventloop for mqtt subscribe

pub fn unsubscribe<S>(&mut self, topic: S) -> Result<(), ClientError> where
    S: Into<String>, 

Requests the eventloop for mqtt unsubscribe

pub fn pause(&mut self) -> Result<(), ClientError>

Commands the network eventloop to disconnect from the broker. ReconnectOptions are not in affect here. Resume the network for reconnection

pub fn resume(&mut self) -> Result<(), ClientError>

Commands the network eventloop to reconnect to the broker and resume network io

pub fn shutdown(&mut self) -> Result<(), ClientError>

Commands the network eventloop to gracefully shutdown the connection to the broker.

Trait Implementations

impl Clone for MqttClient

fn clone(&self) -> MqttClient

Returns a copy of the value.

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

Performs copy-assignment from source.