From d4584452457e83ded1fb0fc92cc82f2b23233104 Mon Sep 17 00:00:00 2001 From: James Strachan Date: Thu, 30 Mar 2006 15:39:15 +0000 Subject: [PATCH] added test case for rendezvous git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390164 13f79535-47bb-0310-9956-ffa450edef68 --- .../discovery/DiscoveryTransportBrokerTest.java | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/activemq-core/src/test/java/org/apache/activemq/transport/discovery/DiscoveryTransportBrokerTest.java b/activemq-core/src/test/java/org/apache/activemq/transport/discovery/DiscoveryTransportBrokerTest.java index b0a4d1fa0b..027681813d 100755 --- a/activemq-core/src/test/java/org/apache/activemq/transport/discovery/DiscoveryTransportBrokerTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/transport/discovery/DiscoveryTransportBrokerTest.java @@ -124,18 +124,22 @@ public class DiscoveryTransportBrokerTest extends NetworkTestSupport { protected TransportConnector createConnector() throws Exception, IOException, URISyntaxException { TransportConnector x = super.createConnector(); - x.setDiscoveryUri(new URI("multicast://default")); + x.setDiscoveryUri(new URI(getDiscoveryUri())); return x; } + + protected String getDiscoveryUri() { + return "multicast://default"; + } protected TransportConnector createRemoteConnector() throws Exception, IOException, URISyntaxException { TransportConnector x = super.createRemoteConnector(); - x.setDiscoveryUri(new URI("multicast://default")); + x.setDiscoveryUri(new URI(getDiscoveryUri())); return x; } protected StubConnection createFailoverConnection() throws Exception { - URI failoverURI = new URI("discovery:multicast://default"); + URI failoverURI = new URI("discovery:" + getDiscoveryUri()); Transport transport = TransportFactory.connect(failoverURI); StubConnection connection = new StubConnection(transport); connections.add(connection);