add decrementInFlight to removeMessage method

ogis-yamazaki · ogis-yamazaki · commit 02d4a1345b1e · 2019-12-09T19:11:21.000+09:00
Signed-off-by: ogis-yamazaki &lt;Yamazaki_Shoji@ogis-ri.co.jp&gt;
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`	`}`