fix for: https://issues.apache.org/jira/browse/AMQ-4822
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/5b6202ba Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/5b6202ba Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/5b6202ba Branch: refs/heads/activemq-5.9 Commit: 5b6202ba4115c82b70be1086b13b85cd5226375b Parents: ab1db02 Author: Timothy Bish <[email protected]> Authored: Thu Oct 24 10:41:05 2013 -0400 Committer: Hadrian Zbarcea <[email protected]> Committed: Tue Mar 11 21:02:08 2014 -0400 ---------------------------------------------------------------------- .../DynamicallyIncludedDestinationsDuplexNetworkTest.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/5b6202ba/activemq-unit-tests/src/test/java/org/apache/activemq/network/DynamicallyIncludedDestinationsDuplexNetworkTest.java ---------------------------------------------------------------------- diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/network/DynamicallyIncludedDestinationsDuplexNetworkTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/network/DynamicallyIncludedDestinationsDuplexNetworkTest.java index 88aa1a2..3dd8be6 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/network/DynamicallyIncludedDestinationsDuplexNetworkTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/network/DynamicallyIncludedDestinationsDuplexNetworkTest.java @@ -21,6 +21,7 @@ import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertNotNull; import java.lang.reflect.Field; +import java.util.concurrent.CopyOnWriteArrayList; import javax.jms.MessageProducer; import javax.jms.TemporaryQueue; @@ -28,6 +29,7 @@ import javax.jms.TemporaryQueue; import org.apache.activemq.advisory.AdvisorySupport; import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.TransportConnection; +import org.apache.activemq.broker.TransportConnector; import org.junit.Test; /** @@ -107,10 +109,9 @@ public class DynamicallyIncludedDestinationsDuplexNetworkTest extends SimpleNetw } public TransportConnection getDuplexBridgeConnectionFromRemote() { - TransportConnection duplexBridgeConnectionFromRemote = - remoteBroker.getTransportConnectorByName("tcp://localhost:" + REMOTE_BROKER_TCP_PORT) - .getConnections().get(0); + TransportConnector transportConnector = remoteBroker.getTransportConnectorByScheme("tcp"); + CopyOnWriteArrayList<TransportConnection> transportConnections = transportConnector.getConnections(); + TransportConnection duplexBridgeConnectionFromRemote = transportConnections.get(0); return duplexBridgeConnectionFromRemote; } - }
