activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hadr...@apache.org
Subject [03/20] git commit: fix for: https://issues.apache.org/jira/browse/AMQ-4822
Date Wed, 12 Mar 2014 02:21:29 GMT
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 <tabish121@gmai.com>
Authored: Thu Oct 24 10:41:05 2013 -0400
Committer: Hadrian Zbarcea <hadrian@apache.org>
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;
     }
-
 }


Mime
View raw message