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