update clean session

amil101 · Jun 3, 2014 · 32d113b · 32d113b
1 parent 6550585
commit 32d113b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/src/main/java/org/apache/jmeter/protocol/mqtt/client/ListenerforSubscribe.java b/src/main/java/org/apache/jmeter/protocol/mqtt/client/ListenerforSubscribe.java
@@ -1,14 +1,14 @@
 package org.apache.jmeter.protocol.mqtt.client;
 
-import java.util.concurrent.atomic.AtomicInteger;
 
+import java.util.concurrent.atomic.AtomicLong;
 import org.fusesource.hawtbuf.Buffer;
 import org.fusesource.hawtbuf.UTF8Buffer;
 import org.fusesource.mqtt.client.Listener;
 
 public class ListenerforSubscribe implements Listener {
 
-	public static AtomicInteger count= new AtomicInteger(0); 
+	public static AtomicLong count= new AtomicLong(0); 
 	@Override
 	public void onConnected() {
 		System.out.println("Subscriber is listening");

diff --git a/src/main/java/org/apache/jmeter/protocol/mqtt/client/MqttSubscriber.java b/src/main/java/org/apache/jmeter/protocol/mqtt/client/MqttSubscriber.java
@@ -295,8 +295,7 @@ public void close(JavaSamplerContext context) {
 				if (this.connectionArray[p] != null) {
 					this.connectionArray[p].unsubscribe(Topics,
 							new CallbackforUnsubscribe());
-					this.connectionArray[p]
-							.disconnect(new CallbackforDisconnect());
+					this.connectionArray[p].disconnect(new CallbackforDisconnect());
 				}
 
 				this.connectionArray[p] = null;