pub: each user stick to his topic

Author: rende2005

mqtt_jmeter/src/main/java/net/xmeter/samplers/ConnectionSampler.java

@@ -134,7 +134,7 @@ public void testEnded(String arg0) {
 	@Override
 	public void testStarted() {
 		keepTime = Integer.parseInt(getConnKeepTime());
-		logger.info("Keeptime is: "  + keepTime);
+		logger.info("*** Keeptime is: "  + keepTime);
 	}
 
 	@Override

mqtt_jmeter/src/main/java/net/xmeter/samplers/PubSampler.java

@@ -29,6 +29,7 @@ public class PubSampler extends AbstractMQTTSampler implements ThreadListener {
 	private String payload = null;
 	private String clientId = "";
 	private QoS qos_enum = QoS.AT_MOST_ONCE;
+	private String topicName = "";
 
 	public String getQOS() {
 		return getPropertyAsString(QOS_LEVEL, String.valueOf(QOS_0));
@@ -117,6 +118,9 @@ public SampleResult sample(Entry arg0) {
 					payload = Util.generatePayload(Integer.parseInt(getMessageLength()));
 				}
 
+				topicName = getTopic();
+				logger.info("*** topicName=" + topicName);
+
 				int qos = Integer.parseInt(getQOS());
 				switch (qos) {
 				case 0:
@@ -143,8 +147,6 @@ public SampleResult sample(Entry arg0) {
 		SampleResult result = new SampleResult();
 		result.setSampleLabel(getName());
 		try {
-			String topicName = getTopic();
-
 			byte[] toSend = new byte[]{};
 			byte[] tmp = new byte[]{};