diff --git a/src/subscriptions.c b/src/subscriptions.c index 2ee76ca..21ff2d0 100644 --- a/src/subscriptions.c +++ b/src/subscriptions.c @@ -54,6 +54,8 @@ void subscription_set_pending(MQTTHandle *handle, char *topic, bool pending) { void dispatch_subscription(MQTTHandle *handle, PublishPayload *payload) { SubscriptionItem *item = handle->subscriptions.items; + // TODO: Handle server Qos + while (item != NULL) { if ((item->pending == false) && (strcmp(payload->topic, item->topic) == 0)) { if (item->handler) {