andry/EMS-ESP32
1
0
Fork 0
mirror of https://github.com/emsesp/EMS-ESP32.git synced 2026-09-13 13:44:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

prevent unsuccessful mqtt connections, dev7

Browse Source
This commit is contained in:
MichaelDvP
2026-08-17 11:37:19 +02:00
parent 822096b635
commit d397a14b41
2 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/core/mqtt.cpp
+3 -4
View File
@@ -351,6 +351,7 @@ void Mqtt::reset_mqtt() {
if (mqttClient_->connected()) { if (mqttClient_->connected()) {
mqttClient_->disconnect(true); // force a disconnect mqttClient_->disconnect(true); // force a disconnect
} }
load_settings(); // reload MQTT settings
} }
// load the settings from service // load the settings from service
@@ -502,8 +503,8 @@ void Mqtt::on_disconnect(espMqttClientTypes::DisconnectReason reason) {
// MQTT on_connect - when an MQTT connect is established // MQTT on_connect - when an MQTT connect is established
void Mqtt::on_connect() { void Mqtt::on_connect() {
if (connecting_) { if (connecting_ || !connected()) {
return; // prevent duplicated connections return; // prevent duplicated connections and unsuccessful tries
} }
LOG_INFO("MQTT connected"); LOG_INFO("MQTT connected");
@@ -511,8 +512,6 @@ void Mqtt::on_connect() {
connecting_ = true; connecting_ = true;
queuecount_ = mqttClient_->queueSize(); queuecount_ = mqttClient_->queueSize();
load_settings(); // reload MQTT settings - in case they have changes
if (ha_enabled_) { if (ha_enabled_) {
queue_unsubscribe_message(discovery_prefix_ + "/+/" + Mqtt::basename() + "/#"); queue_unsubscribe_message(discovery_prefix_ + "/+/" + Mqtt::basename() + "/#");
EMSESP::reset_mqtt_ha(); // re-create all HA devices if there are any EMSESP::reset_mqtt_ha(); // re-create all HA devices if there are any
src/emsesp_version.h
+1 -1
View File
@@ -1 +1 @@
#define EMSESP_APP_VERSION "3.9.0-dev.6" #define EMSESP_APP_VERSION "3.9.0-dev.7"