diff --git a/src/MQTTClient.c b/src/MQTTClient.c index 295505ec..c3effdc4 100644 --- a/src/MQTTClient.c +++ b/src/MQTTClient.c @@ -2080,6 +2080,11 @@ MQTTResponse MQTTClient_subscribeMany5(MQTTClient handle, int count, char* const } else { + if (count < sub->qoss->count) + { + rc = MQTTCLIENT_FAILURE; + goto exit; + } ListElement* current = NULL; i = 0; while (ListNextElement(sub->qoss, ¤t))