From a638c3cb7993d603ca891fdc4fe665202230e498 Mon Sep 17 00:00:00 2001 From: Dreaded_X Date: Sun, 27 Aug 2023 04:11:17 +0200 Subject: [PATCH] Send MQTT message on connect and disconnect --- src/main.rs | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/src/main.rs b/src/main.rs index 3f5a1b1..6185e24 100644 --- a/src/main.rs +++ b/src/main.rs @@ -248,7 +248,7 @@ async fn main(spawner: Spawner) { config.add_max_subscribe_qos(rust_mqtt::packet::v5::publish_packet::QualityOfService::QoS1); config.add_client_id("pico"); // Leads to InsufficientBufferSize error - // config.add_will("pico/test", b"disconnected", false); + config.add_will("pico/test", b"disconnected", false); let mut recv_buffer = [0; 4096]; let mut write_buffer = [0; 4096]; @@ -259,6 +259,16 @@ async fn main(spawner: Spawner) { client.connect_to_broker().await.unwrap(); info!("MQTT Connected!"); + client + .send_message( + "pico/test", + b"connected", + rust_mqtt::packet::v5::publish_packet::QualityOfService::QoS0, + false, + ) + .await + .unwrap(); + // Turn LED off when connected control.gpio_set(0, false).await;