Commit 9401d3e9 authored by Andre Freyssinet's avatar Andre Freyssinet

Adds a random key to the producer/consumer unique id.

parent b521eb86
...@@ -27,6 +27,7 @@ import java.util.ArrayList; ...@@ -27,6 +27,7 @@ import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import java.util.Properties; import java.util.Properties;
import java.util.Random;
import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicLong;
import javax.jms.ConnectionFactory; import javax.jms.ConnectionFactory;
...@@ -63,6 +64,7 @@ public class Helper { ...@@ -63,6 +64,7 @@ public class Helper {
public static final int DFLT_CLEANER_PERIOD = 15; public static final int DFLT_CLEANER_PERIOD = 15;
private Random rand = new Random();
private static final AtomicLong counter = new AtomicLong(1); private static final AtomicLong counter = new AtomicLong(1);
// Singleton // Singleton
private static Helper helper = null; private static Helper helper = null;
...@@ -642,11 +644,11 @@ public class Helper { ...@@ -642,11 +644,11 @@ public class Helper {
} }
public String createProducerId() { public String createProducerId() {
return "prod" + counter.getAndIncrement(); return "prod_" + Math.abs(rand.nextLong()) + "_" + counter.getAndIncrement();
} }
public String createConsumerId() { public String createConsumerId() {
return "cons" + counter.getAndIncrement(); return "cons_" + Math.abs(rand.nextLong()) + "_" + counter.getAndIncrement();
} }
public SessionContext getSessionCtx(String name) { public SessionContext getSessionCtx(String name) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment