Fixed client ids on stan bench

Fixes #119
nats-io · Mar 26, 2019 · 0552e47 · 0552e47
1 parent 429dd5a
commit 0552e47
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -3,6 +3,7 @@
 ## Version 2.1.4
 
 * [Fixed] - #121 - Set protobuf dependency to 3.6.1 to avoid breaking version.
+* [Fixed] - #119 - Fixed issue with client ids in stan bench when multiple subscribers are used.
 
 ## Version 2.1.3
 

diff --git a/src/examples/java/io/nats/streaming/examples/StanBench.java b/src/examples/java/io/nats/streaming/examples/StanBench.java
@@ -183,7 +183,7 @@ public void runSubscriber() throws Exception {
                         .natsConn(nc)
                         .build();
 
-                final StreamingConnection sc = NatsStreaming.connect(clusterId, clientId, opts);
+                final StreamingConnection sc = NatsStreaming.connect(clusterId, this.workerClientId, opts);
                 final SubscriptionOptions sopts;
 
                 if (ignoreOld) {