You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kw...@apache.org on 2017/01/09 10:45:16 UTC
svn commit: r1777948 -
/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/ProducerFlowControlTest.java
Author: kwall
Date: Mon Jan 9 10:45:16 2017
New Revision: 1777948
URL: http://svn.apache.org/viewvc?rev=1777948&view=rev
Log:
NO-JIRA: [Java System Tests] Avoid race condition in test ProducerFlowControlTest
Modified:
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/ProducerFlowControlTest.java
Modified: qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/ProducerFlowControlTest.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/ProducerFlowControlTest.java?rev=1777948&r1=1777947&r2=1777948&view=diff
==============================================================================
--- qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/ProducerFlowControlTest.java (original)
+++ qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/ProducerFlowControlTest.java Mon Jan 9 10:45:16 2017
@@ -77,6 +77,7 @@ public class ProducerFlowControlTest ext
{
_producer.send(_message);
_restTestHelper.waitForAttributeChanged(_queueUrl, org.apache.qpid.server.model.Queue.QUEUE_FLOW_STOPPED, Boolean.TRUE);
+ ((AMQSession<?, ?>) _producerSession).sync(); // Ensure that the client has processed the flow control.
try
{
_producer.send(_message);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org