Allow reconnect

steadramon · Jul 29, 2024 · 0f3d23d · 0f3d23d
1 parent 280cc25
commit 0f3d23d
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/ESPGeiger/src/Mqtt/MQTT_Client.cpp b/ESPGeiger/src/Mqtt/MQTT_Client.cpp
@@ -65,7 +65,7 @@ void MQTT_Client::onMqttDisconnect(AsyncMqttClientDisconnectReason reason) {
      break;
   }
   Log::console(PSTR("MQTT: Disconnected (%s)"),text.c_str());
-  mqttClient->clearQueue();
+  //mqttClient->clearQueue();
   status.mqtt_connected = false;
 }
 
@@ -89,11 +89,15 @@ void MQTT_Client::loop(unsigned long now)
     return;
   }
 
-  if (!status.mqtt_connected) {
+  if (!mqttClient || !mqttClient->connected()) {
     reconnect();
     return;
   }
 
+  if (!status.mqtt_connected) {
+    onMqttConnect(true);
+  }
+
   if (now - lastStatus > statusInterval)
   {
     status.led.Blink(500, 500);