Implemented change to make sure producer and consumer names are unique

jbvanzuylen · Dec 13, 2018 · aa764a8 · aa764a8
1 parent 697737e
commit aa764a8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/src/main/java/org/primeoservices/cfgateway/pulsar/PulsarConsumer.java b/src/main/java/org/primeoservices/cfgateway/pulsar/PulsarConsumer.java
@@ -17,6 +17,7 @@
 
 import java.util.HashMap;
 import java.util.Map;
+import java.util.UUID;
 import java.util.concurrent.TimeUnit;
 
 import org.apache.pulsar.client.api.Consumer;
@@ -63,7 +64,7 @@ public void init(final ConsumerBuilder<byte[]> builder)
   {
     final PulsarConfiguration config = this.getGateway().getConfiguration();
     builder.topic(config.getTopic());
-    builder.consumerName(this.getGateway().getId());
+    builder.consumerName(this.getGateway().getId() + "$" + UUID.randomUUID().toString().substring(0, 5));
     builder.subscriptionName(config.getSubscriptionName());
     builder.subscriptionType(config.getSubscriptionType());
     builder.ackTimeout(config.getAckTimeout(), TimeUnit.SECONDS);

diff --git a/src/main/java/org/primeoservices/cfgateway/pulsar/PulsarProducer.java b/src/main/java/org/primeoservices/cfgateway/pulsar/PulsarProducer.java
@@ -16,6 +16,7 @@
 package org.primeoservices.cfgateway.pulsar;
 
 import java.util.Map;
+import java.util.UUID;
 import java.util.concurrent.TimeUnit;
 
 import org.apache.pulsar.client.api.Producer;
@@ -63,7 +64,7 @@ public void init(final ProducerBuilder<byte[]> builder)
   {
     final PulsarConfiguration config = this.getGateway().getConfiguration();
     builder.topic(config.getTopic());
-    builder.producerName(this.getGateway().getId());
+    builder.producerName(this.getGateway().getId() + "$" + UUID.randomUUID().toString().substring(0, 5));
     builder.sendTimeout(config.getSendTimeout(), TimeUnit.SECONDS);
     builder.enableBatching(false);
   }