Fix core 2.0.12 exception

This commit is contained in:
Theo Arends 2023-09-09 23:04:08 +02:00
parent 4c6ff44e42
commit f9fd813842

View File

@ -911,9 +911,11 @@ void MqttDisconnected(int state) {
Mqtt.retry_counter_delay++;
}
MqttClient.disconnect();
// Check if this solves intermittent MQTT re-connection failures when broker is restarted
EspClient.stop();
if (MqttClient.connected()) {
MqttClient.disconnect();
// Check if this solves intermittent MQTT re-connection failures when broker is restarted
EspClient.stop();
}
AddLog(LOG_LEVEL_INFO, PSTR(D_LOG_MQTT D_CONNECT_FAILED_TO " %s:%d, rc %d. " D_RETRY_IN " %d " D_UNIT_SECOND),
SettingsText(SET_MQTT_HOST), Settings->mqtt_port, state, Mqtt.retry_counter);