diff --git a/automation_lib/src/mqtt.rs b/automation_lib/src/mqtt.rs index b17436a..a908142 100644 --- a/automation_lib/src/mqtt.rs +++ b/automation_lib/src/mqtt.rs @@ -26,6 +26,7 @@ impl From for MqttOptions { let mut mqtt_options = MqttOptions::new(value.client_name, (value.host, value.port)); mqtt_options.set_credentials(value.username, value.password); mqtt_options.set_keep_alive(5); + mqtt_options.set_session_mode(rumqttc::SessionMode::Persistent); if value.tls { mqtt_options.set_transport(Transport::tls_with_default_config());