From c583c2b44a4db6809edc71f32d0fd97640d432c0 Mon Sep 17 00:00:00 2001 From: Gunnar Skjold Date: Sun, 24 Dec 2023 07:03:05 +0100 Subject: [PATCH] Fixed mqtt changed flag --- lib/AmsMqttHandler/include/AmsMqttHandler.h | 1 + lib/AmsMqttHandler/src/AmsMqttHandler.cpp | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/lib/AmsMqttHandler/include/AmsMqttHandler.h b/lib/AmsMqttHandler/include/AmsMqttHandler.h index e8516586..74dd2fac 100644 --- a/lib/AmsMqttHandler/include/AmsMqttHandler.h +++ b/lib/AmsMqttHandler/include/AmsMqttHandler.h @@ -17,6 +17,7 @@ class AmsMqttHandler { public: AmsMqttHandler(MqttConfig& mqttConfig, RemoteDebug* debugger, char* buf) { this->mqttConfig = mqttConfig; + this->mqttConfigChanged = true; this->debugger = debugger; this->json = buf; mqtt.dropOverflow(true); diff --git a/lib/AmsMqttHandler/src/AmsMqttHandler.cpp b/lib/AmsMqttHandler/src/AmsMqttHandler.cpp index abfc3560..fe8c73fb 100644 --- a/lib/AmsMqttHandler/src/AmsMqttHandler.cpp +++ b/lib/AmsMqttHandler/src/AmsMqttHandler.cpp @@ -118,8 +118,8 @@ bool AmsMqttHandler::connect() { actualClient = mqttClient; } + mqttConfigChanged = false; if(debugger->isActive(RemoteDebug::INFO)) debugger->printf_P(PSTR("Connecting to MQTT %s:%d\n"), mqttConfig.host, mqttConfig.port); - mqtt.begin(mqttConfig.host, mqttConfig.port, *actualClient); #if defined(ESP8266)