From 425c785ed930986ac0fb8dbbb9c0e22f6354b7ce Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Thu, 14 Jan 2010 16:53:21 +0000 Subject: QPID-2340 : Fix ProducerFlowControlTest to call a synchronous operation between sends (merged from 0.5-dev) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@899296 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/server/queue/ProducerFlowControlTest.java | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) (limited to 'java/systests/src') 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 d139f8d8b4..aead8eda53 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 @@ -409,8 +409,7 @@ public class ProducerFlowControlTest extends AbstractTestLogging consumer.receive(); //perform a synchronous op on the connection - ((AMQSession) consumerSession).declareExchange( - new AMQShortString("amq.direct"), new AMQShortString("direct"), false); + ((AMQSession) consumerSession).sync(); assertFalse("Queue should not be overfull", queueMBean.isFlowOverfull()); @@ -436,12 +435,15 @@ public class ProducerFlowControlTest extends AbstractTestLogging producer.send(nextMessage(msg, producerSession)); _sentMessages.incrementAndGet(); + try { - Thread.sleep(sleepPeriod); + ((AMQSession)producerSession).sync(); } - catch (InterruptedException e) + catch (AMQException e) { + e.printStackTrace(); + throw new RuntimeException(e); } } } @@ -495,4 +497,4 @@ public class ProducerFlowControlTest extends AbstractTestLogging return _exception; } } -} \ No newline at end of file +} -- cgit v1.2.1