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

https://issues.apache.org/jira/browse/AMQ-4328 - regression in AMQ3274Test, need to sync demand sub creation on async vm transport 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1447715 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2013-02-19 13:33:20 +00:00
parent 97655400e9
commit f4bed15738
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
View File

@ -875,7 +875,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br
protected void addSubscription(DemandSubscription sub) throws IOException {
if (sub != null) {
localBroker.oneway(sub.getLocalInfo());
localBroker.request(sub.getLocalInfo());
}
}

2
activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ3274Test.java
View File

@ -109,8 +109,8 @@ public class AMQ3274Test {
if (cons_client.getNumMsgReceived() == tot_expected) {
LOG.info("Have " + tot_expected + " messages, as-expected");
} else {
LOG.error("Have " + cons_client.getNumMsgReceived() + " messages; expected " + tot_expected);
testError = true;
LOG.info("Have " + cons_client.getNumMsgReceived() + " messages; expected " + tot_expected);
}
resp_cons.close();