From 0f371b6abc54c87a20a807438ff626b467072771 Mon Sep 17 00:00:00 2001
From: bogd <bogd@live.ru>
Date: Fri, 24 Nov 2023 12:27:58 +0200
Subject: [PATCH] fixed MQTT send stack overflow on disconnected socket, no
 keep messages

---
 src/MQTT.c | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/src/MQTT.c b/src/MQTT.c
index 9b1bdc3..445510a 100644
--- a/src/MQTT.c
+++ b/src/MQTT.c
@@ -380,10 +380,8 @@ void MQTTTaskTransmit(void *pvParameter)
         vTaskDelay(pdMS_TO_TICKS(300)); //wait for MQTT queue ready
     while (1)
     {
-        while (!mqtt[idx].is_connected)
-            vTaskDelay(pdMS_TO_TICKS(1000));
         xQueueReceive(mqtt[idx].mqtt_queue, &DSS, portMAX_DELAY);
-        if (mqtt[idx].mqtt)
+        if (mqtt[idx].mqtt && mqtt[idx].is_connected)
         {
 #if MQTT_DEBUG_MODE > 1
             ESP_LOGI(TAG, "MQTT client %d data send:%.*s", idx, DSS.data_length, DSS.raw_data_ptr);
@@ -394,8 +392,8 @@ void MQTTTaskTransmit(void *pvParameter)
                                     DSS.data_length,
                                     0, 0);
         }
-        else
-            ESP_LOGE(TAG, "MQTT client not initialized");
+        //else
+        //    ESP_LOGW(TAG, "MQTT client not initialized or disconnected");
         free(DSS.raw_data_ptr);
     }
 }