Struct for_mqtt_client::protocol::MqttOptions

pub struct MqttOptions { /* private fields */ }

Implementations

impl MqttOptions

pub fn new<S: Into<Arc<String>>, T: Into<String>>( id: S, host: T, port: u16 ) -> Result<MqttOptions>

pub fn auto_reconnect(self) -> Self

设置为自动重连，会默认设置clean_session=false

pub fn set_tls(self, config: TlsConfig) -> Self

pub fn broker_address(&self) -> (String, u16)

Broker address

pub fn set_last_will(self, will: LastWill) -> Self

pub fn last_will(&self) -> Option<LastWill>

pub fn set_keep_alive(self, duration: u16) -> Self

Set number of seconds after which client should ping the broker if there is no other data exchange

pub fn keep_alive(&self) -> u16

Keep alive time

pub fn client_id(&self) -> Arc<String>

Client identifier

pub fn set_max_packet_size(self, incoming: usize, outgoing: usize) -> Self

Set packet size limit for outgoing an incoming packets

pub fn max_packet_size(&self) -> usize

Maximum packet size

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

clean_session = true removes all the state from queues & instructs the broker to clean all the client state when client disconnects.

When set false, broker will hold the client state and performs pending operations on the client when reconnection with same client_id happens. Local queue state is also held to retransmit packets after reconnection.

pub fn clean_session(&self) -> bool

Clean session

pub fn set_credentials<U: Into<Arc<String>>, P1: Into<Arc<String>>>( self, username: U, password: P1 ) -> Self

Username and password

pub fn credentials(&self) -> Option<(Arc<String>, Arc<String>)>

Security options

pub async fn connect_to_v4(self) -> Result<(Client, ClientRx)>

pub async fn connect_to_v5(self) -> Result<(Client, ClientRx)>

Trait Implementations

impl Clone for MqttOptions

fn clone(&self) -> MqttOptions

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for MqttOptions

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

Formats the value using the given formatter.