Module mqtt 

MQTT message publishing.

To receive MQTT messages, use the MQTT trigger.

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)?;

Structs

Connection

An open connection to an MQTT queue.

Enums

Error

Errors related to interacting with Mqtt

Qos

QoS for publishing Mqtt messages

Type Aliases

Payload

The message payload.