activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r661438 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/TopicClusterTest.java
Date Thu, 29 May 2008 19:16:39 GMT
Author: chirino
Date: Thu May 29 12:16:38 2008
New Revision: 661438

URL: http://svn.apache.org/viewvc?rev=661438&view=rev
Log:
Fixed the TopicClusterTest test case.

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/TopicClusterTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/TopicClusterTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/TopicClusterTest.java?rev=661438&r1=661437&r2=661438&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/TopicClusterTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/TopicClusterTest.java
Thu May 29 12:16:38 2008
@@ -60,8 +60,10 @@
     protected MessageProducer[] producers;
     protected Connection[] connections;
     protected List<BrokerService> services = new ArrayList<BrokerService>();
-
+    protected String groupId;
+    
     protected void setUp() throws Exception {
+        groupId = "topic-cluster-test-"+System.currentTimeMillis();
         connections = new Connection[NUMBER_IN_CLUSTER];
         producers = new MessageProducer[NUMBER_IN_CLUSTER];
         Destination destination = createDestination();
@@ -110,7 +112,6 @@
 
         String url = "tcp://localhost:0";
         TransportConnector connector = container.addConnector(url);
-        String groupId = "topic-cluster-test-"+System.currentTimeMillis();
         connector.setDiscoveryUri(new URI("multicast://"+groupId));
         container.addNetworkConnector("multicast://"+groupId);
         container.start();



Mime
View raw message