Merge pull request #721 from ogis-yamazaki/develop

Ranjan Dasgupta · web-flow · commit bce70af40144 · 2020-04-06T23:21:06.000-05:00
Added decrementInFlight on removeMessage to synchronize actualInFlight.
diff --git a/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/ClientState.java b/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/ClientState.java
@@ -682,6 +682,7 @@ protected boolean removeMessage(IMqttDeliveryToken token) throws MqttException {
 			String key =  Integer.toString(messageId);
 			tokenStore.removeToken(key);
 			releaseMessageId(messageId);
+			decrementInFlight();
 		}
 		return result;
 	}

Original file line number	Diff line number	Diff line change
`@@ -682,6 +682,7 @@ protected boolean removeMessage(IMqttDeliveryToken token) throws MqttException {`
`682`	`682`	`String key = Integer.toString(messageId);`
`683`	`683`	`tokenStore.removeToken(key);`
`684`	`684`	`releaseMessageId(messageId);`
	`685`	`+ decrementInFlight();`
`685`	`686`	`}`
`686`	`687`	`return result;`
`687`	`688`	`}`