Struct Connection 

pub struct Connection(/* private fields */);

Available on crate feature mqtt only.

An open connection to an MQTT queue.

The address must be in URL form, and must include a client_id: mqtt://hostname?client_id=...

Examples

Send an MQTT message.

use spin_sdk::mqtt::{Connection, Qos};

let conn = Connection::open(
    "mqtt://localhost:1883?client_id=123",
    "user",
    "password",
    30 /* seconds */
).await?;

let payload = b"hello mqtt".to_vec();

conn.publish("pet-pictures", payload, Qos::AtLeastOnce).await?;

Implementations

impl Connection

pub async fn open( address: impl AsRef<str>, username: impl AsRef<str>, password: impl AsRef<str>, keep_alive_interval_in_secs: u64, ) -> Result<Self, Error>

Open a connection to the Mqtt instance at address.

pub async fn publish( &self, topic: impl AsRef<str>, payload: Vec<u8>, qos: Qos, ) -> Result<(), Error>

Publish an Mqtt message to the specified topic.