| commit | 03455261edd8eedee2ec73d097019d64a9765bdb | [log] [tgz] |
|---|---|---|
| author | Alex Rudyy <orudyy@apache.org> | Fri Apr 10 15:59:29 2015 +0000 |
| committer | Alex Rudyy <orudyy@apache.org> | Fri Apr 10 15:59:29 2015 +0000 |
| tree | 8ee8032bcda15b80038e595ce8cf153a319ae667 | |
| parent | 46ab4589075bb8bf35020c782676d4f097cd8edf [diff] |
Fix failing FailoverBehaviourTest#testFlowControlFlagResetOnFailover git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1672692 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/qpid/java/systests/src/test/java/org/apache/qpid/client/failover/FailoverBehaviourTest.java b/qpid/java/systests/src/test/java/org/apache/qpid/client/failover/FailoverBehaviourTest.java index a224247..7878032 100644 --- a/qpid/java/systests/src/test/java/org/apache/qpid/client/failover/FailoverBehaviourTest.java +++ b/qpid/java/systests/src/test/java/org/apache/qpid/client/failover/FailoverBehaviourTest.java
@@ -1001,10 +1001,9 @@ } assertTrue("Flow is not blocked", ((AMQSession<?, ?>) producerSession).isFlowBlocked()); - // Message counter could be 3 or 4 depending on the progression of producing thread relative - // to the receipt of the ChannelFlow. + final int currentCounter = counter.get(); - assertTrue("Unexpected number of sent messages", currentCounter == 3 || currentCounter == 4); + assertTrue("Unexpected number of sent messages:" + currentCounter, currentCounter >=3); killBroker(); startBroker();