You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2011/01/17 17:31:01 UTC
svn commit: r1059979 - /camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/CamelJmsTestHelper.java

Author: davsclaus
Date: Mon Jan 17 16:31:00 2011
New Revision: 1059979

URL: http://svn.apache.org/viewvc?rev=1059979&view=rev
Log:
Using an counter instead of random number for unique broker name. Thats much better :)

Modified:
    camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/CamelJmsTestHelper.java

Modified: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/CamelJmsTestHelper.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/CamelJmsTestHelper.java?rev=1059979&r1=1059978&r2=1059979&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/CamelJmsTestHelper.java (original)
+++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/CamelJmsTestHelper.java Mon Jan 17 16:31:00 2011
@@ -16,7 +16,7 @@
  */
 package org.apache.camel.component.jms;
 
-import java.util.Random;
+import java.util.concurrent.atomic.AtomicInteger;
 import javax.jms.ConnectionFactory;
 
 import org.apache.activemq.ActiveMQConnectionFactory;
@@ -28,22 +28,22 @@ import org.apache.activemq.ActiveMQConne
  */
 public final class CamelJmsTestHelper {
 
-    private static Random ran = new Random();
+    private static AtomicInteger counter = new AtomicInteger(0);
 
     private CamelJmsTestHelper() {
     }
 
     public static ConnectionFactory createConnectionFactory() {
         // using a unique broker name improves testing when running the entire test suite in the same JVM
-        int id = ran.nextInt(100000);
-        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://broker-" + id + "?broker.persistent=false&broker.useJmx=false");
+        int id = counter.incrementAndGet();
+        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://test-broker-" + id + "?broker.persistent=false&broker.useJmx=false");
         return connectionFactory;
     }
 
     public static ConnectionFactory createPersistentConnectionFactory() {
         // using a unique broker name improves testing when running the entire test suite in the same JVM
-        int id = ran.nextInt(100000);
-        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://broker-" + id + "?broker.persistent=true&broker.useJmx=false");
+        int id = counter.incrementAndGet();
+        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://test-broker-" + id + "?broker.persistent=true&broker.useJmx=false");
         return connectionFactory;
     }
 }