Struct MqttClientBuilder

pub struct MqttClientBuilder { /* private fields */ }

Implementations

impl MqttClientBuilder

pub fn new(url: Url) -> Self

pub fn client_id<S: Into<String>>(self, client_id: S) -> Self

pub fn clean_session(self, clean_session: bool) -> Self

When the clean session flag is set to true, the client does not want a persistent session. If the client disconnects for any reason, all information and messages that are queued from a previous persistent session are lost.

When the clean session flag is set to false, the broker creates a persistent session for the client. All information and messages are preserved until the next time that the client requests a clean session. If the clean session flag is set to false and the broker already has a session available for the client, it uses the existing session and delivers previously queued messages to the client.

pub fn subscribe<S: Into<String>>(self, filter: S, qos: QoS) -> Self

pub fn on_message_callback<F>(self, callback: F) -> Self

where F: Fn(&Message) + Send + Sync + 'static,

pub fn on_connected_callback<F>(self, callback: F) -> Self

where F: Fn() + Send + Sync + 'static,

pub fn on_message_owned_callback<F>(self, callback: F) -> Self

where F: Fn(Message, Instant) + Send + 'static,

pub fn build(self) -> (MqttClient, MqttWorker)