svn commit: r794315 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/discovery/DiscoveryTransportBrokerTest.java

[gtully]

Author: gtully
Date: Wed Jul 15 16:03:24 2009
New Revision: 794315

URL: http://svn.apache.org/viewvc?rev=794315&view=rev
Log:
resolve intermittent failure resulting from fix for 
https://issues.apache.org/activemq/browse/AMQ-2283 - match of url needs to take 
account of absent query parameters in broadcast address

Modified:
    
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/discovery/DiscoveryTransportBrokerTest.java

Modified: 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/discovery/DiscoveryTransportBrokerTest.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/discovery/DiscoveryTransportBrokerTest.java?rev=794315&r1=794314&r2=794315&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/discovery/DiscoveryTransportBrokerTest.java
 (original)
+++ 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/discovery/DiscoveryTransportBrokerTest.java
 Wed Jul 15 16:03:24 2009
@@ -91,7 +91,7 @@
         StubConnection connectionA;
         StubConnection connectionB;
         TransportConnector serverA;
-        if 
(connector.getServer().getConnectURI().equals(ft.getConnectedTransportURI())) {
+        if (connector.getServer().getConnectURI().getPort() == 
ft.getConnectedTransportURI().getPort()) {
             connectionA = connection1;
             connectionB = connection2;
             serverA = connector;