diff --git a/src/mqttdpms.rs b/src/mqttdpms.rs index c4615ba..30620ae 100644 --- a/src/mqttdpms.rs +++ b/src/mqttdpms.rs @@ -170,7 +170,7 @@ impl MqttDpms { .topics .availability .replace("@UNIQUEID@", &self.config.unique_id); - let message = mqtt::Message::new(topic, "online", 0); + let message = mqtt::Message::new_retained(topic, "online", 0); Ok(client.publish(message).await?) }