|
@ -0,0 +1,12 @@ |
|
|
|
|
|
diff --git a/lib/mosquitto.c b/lib/mosquitto.c
|
|
|
|
|
|
index bd9dbd3..7314248 100644
|
|
|
|
|
|
--- a/lib/mosquitto.c
|
|
|
|
|
|
+++ b/lib/mosquitto.c
|
|
|
|
|
|
@@ -594,7 +594,6 @@ int mosquitto_publish(struct mosquitto *mosq, int *mid, const char *topic, int p
|
|
|
|
|
|
pthread_mutex_lock(&mosq->out_message_mutex); |
|
|
|
|
|
_mosquitto_message_queue(mosq, message, mosq_md_out); |
|
|
|
|
|
if(mosq->max_inflight_messages == 0 || mosq->inflight_messages < mosq->max_inflight_messages){ |
|
|
|
|
|
- mosq->inflight_messages++;
|
|
|
|
|
|
if(qos == 1){ |
|
|
|
|
|
message->state = mosq_ms_wait_for_puback; |
|
|
|
|
|
}else if(qos == 2){ |