From 2996e4175d51eb0d4307335ee3a8ace1d6823a02 Mon Sep 17 00:00:00 2001
From: bogd <bogd@live.ru>
Date: Tue, 27 Feb 2024 13:22:15 +0200
Subject: [PATCH] Queue in MQTT transport wait for connected

---
 src/MQTT.c | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/MQTT.c b/src/MQTT.c
index 954e928..a720e45 100644
--- a/src/MQTT.c
+++ b/src/MQTT.c
@@ -383,9 +383,12 @@ 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(300));
         xQueueReceive(mqtt[idx].mqtt_queue, &DSS, portMAX_DELAY);
         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);
 #endif
@@ -547,7 +550,7 @@ esp_err_t ExtendedLog(esp_log_level_t level, char *format, ...)
             strcpy(buf, time);
             strcat(buf, "  ");
             strcat(buf, data);
-            MQTT_DATA_SEND_STRUCT DSS = {0};
+            MQTT_DATA_SEND_STRUCT DSS = { 0 };
             ComposeTopic(DSS.topic, idx, "LOG", "UPLINK");
             DSS.raw_data_ptr = buf;
             DSS.data_length = strlen(buf);