activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r355921 - /incubator/activemq/assembly/src/test/org/activemq/transport/TopicClusterTest.java
Date Sun, 11 Dec 2005 05:38:02 GMT
Author: chirino
Date: Sat Dec 10 21:37:59 2005
New Revision: 355921

URL: http://svn.apache.org/viewcvs?rev=355921&view=rev
Log:
use new discovery apis.

Modified:
    incubator/activemq/assembly/src/test/org/activemq/transport/TopicClusterTest.java

Modified: incubator/activemq/assembly/src/test/org/activemq/transport/TopicClusterTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/assembly/src/test/org/activemq/transport/TopicClusterTest.java?rev=355921&r1=355920&r2=355921&view=diff
==============================================================================
--- incubator/activemq/assembly/src/test/org/activemq/transport/TopicClusterTest.java (original)
+++ incubator/activemq/assembly/src/test/org/activemq/transport/TopicClusterTest.java Sat
Dec 10 21:37:59 2005
@@ -21,6 +21,7 @@
 
 import org.activemq.ActiveMQConnectionFactory;
 import org.activemq.broker.BrokerService;
+import org.activemq.broker.TransportConnector;
 import org.activemq.command.ActiveMQQueue;
 import org.activemq.command.ActiveMQTextMessage;
 import org.activemq.command.ActiveMQTopic;
@@ -41,6 +42,7 @@
 import javax.jms.Session;
 import javax.jms.TextMessage;
 
+import java.net.URI;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -109,10 +111,10 @@
         BrokerService container = new BrokerService();
         container.setBrokerName(brokerName);
       
-        String url = "discovery:tcp://localhost:0";
-        container.addConnector(url);
-        
-        container.addNetworkConnector("multicast");
+        String url = "tcp://localhost:0";
+        TransportConnector connector = container.addConnector(url);
+        connector.setDiscoveryUri(new URI("multicast://default"));        
+        container.addNetworkConnector("multicast://default");
         container.start();
         
         services.add(container);



Mime
View raw message