qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rob...@apache.org
Subject svn commit: r892231 - in /qpid/branches/0.5.x-dev/qpid/java: ./ systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java
Date Fri, 18 Dec 2009 11:59:11 GMT
Author: robbie
Date: Fri Dec 18 11:59:11 2009
New Revision: 892231

URL: http://svn.apache.org/viewvc?rev=892231&view=rev
Log:
QPID-2177: insert a synchronous operation to alleviate the recieve race condition in the test

merge from trunk r892228

Modified:
    qpid/branches/0.5.x-dev/qpid/java/   (props changed)
    qpid/branches/0.5.x-dev/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java

Propchange: qpid/branches/0.5.x-dev/qpid/java/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Fri Dec 18 11:59:11 2009
@@ -1,2 +1,2 @@
 /qpid/branches/java-broker-0-10/qpid/java:829414,829575
-/qpid/trunk/qpid/java:835115,884634-884635,884838,885765,887948,887950-887952,887994,888246,888248,888250,888345,888348,889645,891323-891332
+/qpid/trunk/qpid/java:835115,884634-884635,884838,885765,887948,887950-887952,887994,888246,888248,888250,888345,888348,889645,891323-891332,892228

Modified: qpid/branches/0.5.x-dev/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java
URL: http://svn.apache.org/viewvc/qpid/branches/0.5.x-dev/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java?rev=892231&r1=892230&r2=892231&view=diff
==============================================================================
--- qpid/branches/0.5.x-dev/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java
(original)
+++ qpid/branches/0.5.x-dev/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/ProducerFlowControlTest.java
Fri Dec 18 11:59:11 2009
@@ -405,6 +405,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:commits-subscribe@qpid.apache.org


Mime
View raw message