svn commit: r355921 - /incubator/activemq/assembly/src/test/org/activemq/transport/TopicClusterTest.java

[chirino]

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);