Fix Bug 455911 - Subscription Callback invoked a second time when connection gets dropped

bzhangxmt · bzhangxmt · commit 851e3c8b0335 · 2014-12-22T11:20:43.000+08:00
Signed-off-by: bzhangxmt &lt;zhbinbj@cn.ibm.com&gt;
diff --git a/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/CommsCallback.java b/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/CommsCallback.java
@@ -212,7 +212,7 @@ private void handleActionComplete(MqttToken token)
 			
 			// Set notified so we don't tell the user again about this action.
  			if ( token.isComplete() ){
- 			   if ( token instanceof MqttDeliveryToken || token.getActionCallback() instanceof ConnectActionListener ) {
+ 			   if ( token instanceof MqttDeliveryToken || token.getActionCallback() instanceof IMqttActionListener ) {
  	                token.internalTok.setNotified(true);
  	            }
  			}

Original file line number	Diff line number	Diff line change
`@@ -212,7 +212,7 @@ private void handleActionComplete(MqttToken token)`
`212`	`212`
`213`	`213`	`// Set notified so we don't tell the user again about this action.`
`214`	`214`	`if ( token.isComplete() ){`
`215`		`- if ( token instanceof MqttDeliveryToken \|\| token.getActionCallback() instanceof ConnectActionListener ) {`
	`215`	`+ if ( token instanceof MqttDeliveryToken \|\| token.getActionCallback() instanceof IMqttActionListener ) {`
`216`	`216`	`token.internalTok.setNotified(true);`
`217`	`217`	`}`
`218`	`218`	`}`