Struct Connection 

pub struct Connection { /* private fields */ }

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 user = spin_sdk::variables::get("mqtt_username")?;
let password = spin_sdk::variables::get("mqtt_password")?;

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

let payload = request.body().to_vec();
ensure_pet_picture(&payload)?;

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

Implementations

impl Connection

pub fn open( address: &str, username: &str, password: &str, keep_alive_interval_in_secs: u64, ) -> Result<Connection, Error>

Open a connection to the Mqtt instance at address.

impl Connection

pub fn publish( &self, topic: &str, payload: &[u8], qos: Qos, ) -> Result<(), Error>

Publish an Mqtt message to the specified topic.

Trait Implementations

impl Debug for Connection

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

Formats the value using the given formatter.