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

show mqtt stop

Browse Source
This commit is contained in:
MichaelDvP
2026-09-05 09:53:31 +02:00
parent 5f548c3287
commit 3ba7099987
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ESP32React/MqttSettingsService.cpp
+5 -1
View File
@@ -84,7 +84,7 @@ void MqttSettingsService::loop() {
} }
if (_reconfigureMqtt || (_disconnectedAt && static_cast<uint32_t>(uuid::get_uptime() - _disconnectedAt) >= MQTT_RECONNECTION_DELAY)) { if (_reconfigureMqtt || (_disconnectedAt && static_cast<uint32_t>(uuid::get_uptime() - _disconnectedAt) >= MQTT_RECONNECTION_DELAY)) {
// configure MQTT client // configure MQTT client
if (_reconfigureMqtt) { if (_reconfigureMqtt && _state.enabled) {
emsesp::EMSESP::logger().info("Starting MQTT service"); emsesp::EMSESP::logger().info("Starting MQTT service");
} }
_disconnectedAt = configureMqtt() ? 0 : uuid::get_uptime(); _disconnectedAt = configureMqtt() ? 0 : uuid::get_uptime();
@@ -130,6 +130,7 @@ MqttClient * MqttSettingsService::getMqttClient() {
void MqttSettingsService::onMqttConnect(bool sessionPresent) { void MqttSettingsService::onMqttConnect(bool sessionPresent) {
(void)sessionPresent; (void)sessionPresent;
emsesp::EMSESP::mqtt_.on_connect(); emsesp::EMSESP::mqtt_.on_connect();
_disconnectReason = espMqttClientTypes::DisconnectReason::USER_OK;
} }
void MqttSettingsService::onMqttDisconnect(espMqttClientTypes::DisconnectReason reason) { void MqttSettingsService::onMqttDisconnect(espMqttClientTypes::DisconnectReason reason) {
@@ -158,6 +159,9 @@ bool MqttSettingsService::configureMqtt() {
emsesp::EMSESP::logger().debug("Disconnecting to configure"); emsesp::EMSESP::logger().debug("Disconnecting to configure");
#endif #endif
_mqttClient->disconnect(true); _mqttClient->disconnect(true);
if (!_state.enabled) {
emsesp::EMSESP::logger().info("Stopping MQTT client");
}
} }
// only connect if WiFi is connected and MQTT is enabled // only connect if WiFi is connected and MQTT is enabled