diff options
Diffstat (limited to 'java/systests')
| -rw-r--r-- | java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java | 12 |
1 files changed, 7 insertions, 5 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 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 +} |