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)