You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2008/05/29 21:16:39 UTC
svn commit: r661438 -
/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/TopicClusterTest.java
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();