diff options
-rw-r--r-- | java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java b/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java index f220760511..2d9ce35d29 100644 --- a/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java +++ b/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java @@ -184,7 +184,7 @@ public class ProducerFlowControlTest extends AbstractTestLogging Thread.sleep(10000); List<String> results = _monitor.findMatches("Message send delayed by"); - assertEquals("Incorrect number of delay messages logged by client",3,results.size()); + assertTrue("No delay messages logged by client",results.size()!=0); results = _monitor.findMatches("Message send failed due to timeout waiting on broker enforced flow control"); assertEquals("Incorrect number of send failure messages logged by client",1,results.size()); |