From 9e05f92cbf1a60a4a4e1e19ad6a93a0341eb32c9 Mon Sep 17 00:00:00 2001 From: bogd Date: Wed, 18 Oct 2023 15:53:30 +0200 Subject: [PATCH] fixed issue with mqtt queue overloaded --- src/MQTT.c | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/MQTT.c b/src/MQTT.c index ff4b81d..9b66474 100644 --- a/src/MQTT.c +++ b/src/MQTT.c @@ -126,11 +126,12 @@ esp_err_t SysServiceMQTTSend(char *data, int len, int idx) ComposeTopic(DSS.topic, idx, SERVICE_NAME, UPLINK_SUBTOPIC); DSS.raw_data_ptr = buf; DSS.data_length = len; - if (xQueueSend(GetMQTTHandlesPool(idx)->mqtt_queue, &DSS, pdMS_TO_TICKS(1000)) == pdPASS) + if (xQueueSend(GetMQTTHandlesPool(idx)->mqtt_queue, &DSS, pdMS_TO_TICKS(0)) == pdPASS) return ESP_OK; else { free(buf); + ESP_LOGW(TAG, "MQTT message queue is full on client %d", idx); return ESP_ERR_TIMEOUT; } } @@ -149,11 +150,12 @@ esp_err_t ExternalServiceMQTTSend(char *data, int len, int idx) ComposeTopic(DSS.topic, idx, EXTERNAL_SERVICE_NAME, UPLINK_SUBTOPIC); DSS.raw_data_ptr = buf; DSS.data_length = len; - if (xQueueSend(GetMQTTHandlesPool(idx)->mqtt_queue, &DSS, pdMS_TO_TICKS(1000)) == pdPASS) + if (xQueueSend(GetMQTTHandlesPool(idx)->mqtt_queue, &DSS, pdMS_TO_TICKS(0)) == pdPASS) return ESP_OK; else { free(buf); + ESP_LOGW(TAG, "MQTT message queue is full on client %d", idx); return ESP_ERR_TIMEOUT; } }