Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

quick sanity of non duplex case 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1440502 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2013-01-30 16:21:02 +00:00
parent b1a7e75099
commit a8b6f8bb45
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
activemq-unit-tests/src/test/java/org/apache/activemq/usecases/RequestReplyToTopicViaThreeNetworkHopsTest.java
View File

@ -63,6 +63,7 @@ public class RequestReplyToTopicViaThreeNetworkHopsTest {
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 RequestReplyToTopicViaThreeNetworkHopsTest {
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 RequestReplyToTopicViaThreeNetworkHopsTest {
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()