Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-17 07:24:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

added test case for rendezvous

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390164 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2006-03-30 15:39:15 +00:00
parent 1a917fe88f
commit d458445245
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
activemq-core/src/test/java/org/apache/activemq/transport/discovery/DiscoveryTransportBrokerTest.java
View File

@ -124,18 +124,22 @@ public class DiscoveryTransportBrokerTest extends NetworkTestSupport {
protected TransportConnector createConnector() throws Exception, IOException, URISyntaxException { protected TransportConnector createConnector() throws Exception, IOException, URISyntaxException {
TransportConnector x = super.createConnector(); TransportConnector x = super.createConnector();
x.setDiscoveryUri(new URI("multicast://default")); x.setDiscoveryUri(new URI(getDiscoveryUri()));
return x; return x;
} }
protected String getDiscoveryUri() {
return "multicast://default";
}
protected TransportConnector createRemoteConnector() throws Exception, IOException, URISyntaxException { protected TransportConnector createRemoteConnector() throws Exception, IOException, URISyntaxException {
TransportConnector x = super.createRemoteConnector(); TransportConnector x = super.createRemoteConnector();
x.setDiscoveryUri(new URI("multicast://default")); x.setDiscoveryUri(new URI(getDiscoveryUri()));
return x; return x;
} }
protected StubConnection createFailoverConnection() throws Exception { protected StubConnection createFailoverConnection() throws Exception {
URI failoverURI = new URI("discovery:multicast://default"); URI failoverURI = new URI("discovery:" + getDiscoveryUri());
Transport transport = TransportFactory.connect(failoverURI); Transport transport = TransportFactory.connect(failoverURI);
StubConnection connection = new StubConnection(transport); StubConnection connection = new StubConnection(transport);
connections.add(connection); connections.add(connection);