feat: Reconnect to mqtt when connection is lost

2026-08-26 05:45:43 +02:00
1 changed files with 1 additions and 0 deletions
@@ -26,6 +26,7 @@ impl From<MqttConfig> 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());