Author: robbie
Date: Fri Dec 18 11:50:17 2009
New Revision: 892228
URL: http://svn.apache.org/viewvc?rev=892228&view=rev
Log:
QPID-2177: insert a synchronous operation to alleviate the recieve race
condition in the test
Modified:
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java
Modified:
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java?rev=892228&r1=892227&r2=892228&view=diff
==============================================================================
---
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java
(original)
+++
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java
Fri Dec 18 11:50:17 2009
@@ -407,6 +407,11 @@
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();
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
