diff --git a/src/mqtt/new_mqtt.h b/src/mqtt/new_mqtt.h index 8dc042321..b29b1fc82 100644 --- a/src/mqtt/new_mqtt.h +++ b/src/mqtt/new_mqtt.h @@ -99,7 +99,7 @@ typedef struct MqttPublishItem // Count of queued items published at once. #define MQTT_QUEUED_ITEMS_PUBLISHED_AT_ONCE 3 -#define MQTT_MAX_QUEUE_SIZE 7 +#define MQTT_MAX_QUEUE_SIZE 16 // callback function for mqtt. // return 0 to allow the incoming topic/data to be processed by others/channel set.