diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/systests/src/test/java/org/apache/qpid/client/failover/FailoverBehaviourTest.java | 5 |
1 files changed, 2 insertions, 3 deletions
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 a2242475eb..7878032253 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 @@ public class FailoverBehaviourTest extends FailoverBaseCase implements Connectio } 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(); |