svn commit: r1440502 - /activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/RequestReplyToTopicViaThreeNetworkHopsTest.java

[gt...@apache.org]

Author: gtully
Date: Wed Jan 30 16:21:02 2013
New Revision: 1440502

URL: http://svn.apache.org/viewvc?rev=1440502&view=rev
Log:
quick sanity of non duplex case

Modified:
    activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/RequestReplyToTopicViaThreeNetworkHopsTest.java

Modified: activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/RequestReplyToTopicViaThreeNetworkHopsTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/RequestReplyToTopicViaThreeNetworkHopsTest.java?rev=1440502&r1=1440501&r2=1440502&view=diff
==============================================================================
--- activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/RequestReplyToTopicViaThreeNetworkHopsTest.java (original)
+++ activemq/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/RequestReplyToTopicViaThreeNetworkHopsTest.java Wed Jan 30 16:21:02 2013
@@ -63,6 +63,7 @@ public class RequestReplyToTopicViaThree
     protected int echoResponseFill = 0;   // Number of "filler" response messages per request
 
     protected static Log LOG;
+    public boolean duplex = true;
 
     static {
         LOG = LogFactory.getLog(RequestReplyToTopicViaThreeNetworkHopsTest.class);
@@ -76,9 +77,9 @@ public class RequestReplyToTopicViaThree
         core2 = new EmbeddedTcpBroker("core", 2);
 
         // duplex is necessary to serialise sends with consumer/destination creation
-        edge1.coreConnectTo(core1, true);
-        edge2.coreConnectTo(core2, true);
-        core1.coreConnectTo(core2, true);
+        edge1.coreConnectTo(core1, duplex);
+        edge2.coreConnectTo(core2, duplex);
+        core1.coreConnectTo(core2, duplex);
 
     }
 
@@ -616,6 +617,10 @@ public class RequestReplyToTopicViaThree
                 throws Exception {
             this.makeConnectionTo(other, duplex_f, true);
             this.makeConnectionTo(other, duplex_f, false);
+            if (!duplex_f) {
+                other.makeConnectionTo(this, duplex_f, true);
+                other.makeConnectionTo(this, duplex_f, false);
+            }
         }
 
         public void start()