Repository: qpid-jms Updated Branches: refs/heads/master b103810ba -> fea02ac5c
NO-JIRA Fix test to account for so that flow is emitted always For the no listener case we should emit a flow so that the two cases are consistent. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/fea02ac5 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/fea02ac5 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/fea02ac5 Branch: refs/heads/master Commit: fea02ac5cd2e25de24c68c12c27914de2884d3c0 Parents: b103810 Author: Timothy Bish <[email protected]> Authored: Wed Jul 18 15:23:55 2018 -0400 Committer: Timothy Bish <[email protected]> Committed: Wed Jul 18 15:23:55 2018 -0400 ---------------------------------------------------------------------- .../qpid/jms/provider/failover/FailoverIntegrationTest.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/fea02ac5/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/failover/FailoverIntegrationTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/failover/FailoverIntegrationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/failover/FailoverIntegrationTest.java index c38ba8d..0a80741 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/failover/FailoverIntegrationTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/failover/FailoverIntegrationTest.java @@ -2637,8 +2637,15 @@ public class FailoverIntegrationTest extends QpidJmsTestCase { finalPeer.expectReceiverAttach(notNullValue(), notNullValue(), false, true, false, false, errorCondition, errorDescription); finalPeer.expectDetach(true, false, false); + final int prefetch; + if (addListener) { + prefetch = 0; + } else { + prefetch = 1; + } + final JmsConnection connection = establishAnonymousConnecton( - "jms.prefetchPolicy.all=0&jms.closeLinksThatFailOnReconnect=true", originalPeer, finalPeer); + "jms.prefetchPolicy.all="+ prefetch + "&jms.closeLinksThatFailOnReconnect=true", originalPeer, finalPeer); connection.setExceptionListener(new ExceptionListener() { @Override public void onException(JMSException exception) { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
