Struct rumqtt::MqttClient
[−]
[src]
pub struct MqttClient {
pub nw_request_tx: SyncSender<NetworkRequest>,
}Fields
nw_request_tx: SyncSender<NetworkRequest>
Methods
impl MqttClient[src]
fn start(opts: MqttOptions, callbacks: Option<MqttCallback>) -> Result<Self>[src]
Connects to the broker and starts an event loop in a new thread. Returns 'Request' and handles reqests from it. Also handles network events, reconnections and retransmissions.
fn subscribe(&mut self, topics: Vec<(&str, QualityOfService)>) -> Result<()>[src]
fn publish(
&mut self,
topic: &str,
qos: QualityOfService,
payload: Vec<u8>
) -> Result<()>[src]
&mut self,
topic: &str,
qos: QualityOfService,
payload: Vec<u8>
) -> Result<()>
fn retained_publish(
&mut self,
topic: &str,
qos: QualityOfService,
payload: Vec<u8>
) -> Result<()>[src]
&mut self,
topic: &str,
qos: QualityOfService,
payload: Vec<u8>
) -> Result<()>
fn userdata_publish(
&mut self,
topic: &str,
qos: QualityOfService,
payload: Vec<u8>,
userdata: Vec<u8>
) -> Result<()>[src]
&mut self,
topic: &str,
qos: QualityOfService,
payload: Vec<u8>,
userdata: Vec<u8>
) -> Result<()>
fn retained_userdata_publish(
&mut self,
topic: &str,
qos: QualityOfService,
payload: Vec<u8>,
userdata: Vec<u8>
) -> Result<()>[src]
&mut self,
topic: &str,
qos: QualityOfService,
payload: Vec<u8>,
userdata: Vec<u8>
) -> Result<()>