diff --git a/lib/messages_mosq.c b/lib/messages_mosq.c index 84afda76..eb10dcab 100644 --- a/lib/messages_mosq.c +++ b/lib/messages_mosq.c @@ -277,9 +277,6 @@ int _mosquitto_message_remove(struct mosquitto *mosq, uint16_t mid, enum mosquit }else if(!mosq->in_messages){ mosq->in_messages_last = NULL; } - if(cur->msg.qos == 2){ - mosq->inflight_messages--; - } found = true; break; }