Minor chane, fixed integration scripts for many connections

2015-12-06 19:04:26 +01:00
parent 9ce9a6597f
commit 585bf7523e
2 changed files with 3 additions and 2 deletions
@@ -31,7 +31,7 @@ class PublisherThread extends Thread {
        mqtt.setCleanSession(true)
        mqtt.setHost(host, 1883)

-        def postFix = oneClientPerTopic ? subId : ""
+        def postFix = oneClientPerTopic ? "" : pubId

        mqtt.setClientId("PublisherClient${pubId}")
        BlockingConnection connection = mqtt.blockingConnection()