Struct MqttClient 

pub struct MqttClient { /* private fields */ }

Async MQTT client.

Internally owns both the rumqttc::AsyncClient (for publish/subscribe) and the rumqttc::EventLoop (which must be polled continuously to keep the connection alive).

Implementations

impl MqttClient

pub fn new(config: MqttConfig) -> Result<(Self, EventLoop)>

Create a new client and connect to the broker described by config.

The returned EventLoop must be driven by calling MqttClient::run_event_loop or by polling it manually in a dedicated task.

pub async fn publish_message( &self, topic: &str, message: &Message, ) -> Result<()>

Publish a serialised Message to the given topic.

pub async fn publish_json( &self, topic: &str, payload: &impl Serialize, ) -> Result<()>

Publish a raw JSON payload to the given topic.

pub async fn publish_raw(&self, topic: &str, payload: Vec<u8>) -> Result<()>

Publish raw bytes to the given topic.

pub async fn subscribe(&self, topic: &str) -> Result<()>

Subscribe to a topic pattern (MQTT wildcards + and # supported).

pub async fn unsubscribe(&self, topic: &str) -> Result<()>

Unsubscribe from a topic.

pub async fn run_event_loop( event_loop: &mut EventLoop, handler: impl FnMut(MqttEvent) + Send + 'static, )

Drive the event loop, mapping raw rumqttc events to MqttEvents and forwarding them to handler.

This method loops forever; call it in a dedicated tokio::spawn task.