From 8cc7c55464edb03d8a45f688a34b85c9a08766de Mon Sep 17 00:00:00 2001 From: Robert Gemmell Date: Fri, 18 Dec 2009 11:50:17 +0000 Subject: QPID-2177: insert a synchronous operation to alleviate the recieve race condition in the test git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@892228 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/qpid/server/queue/ProducerFlowControlTest.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java index ecb2f7d559..d139f8d8b4 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java @@ -407,6 +407,11 @@ public class ProducerFlowControlTest extends AbstractTestLogging consumerConnection.start(); consumer.receive(); + + //perform a synchronous op on the connection + ((AMQSession) consumerSession).declareExchange( + new AMQShortString("amq.direct"), new AMQShortString("direct"), false); + assertFalse("Queue should not be overfull", queueMBean.isFlowOverfull()); consumer.receive(); -- cgit v1.2.1