activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r745480 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java
Date Wed, 18 Feb 2009 11:43:29 GMT
Author: gtully
Date: Wed Feb 18 11:43:29 2009
New Revision: 745480

URL: http://svn.apache.org/viewvc?rev=745480&view=rev
Log:
partial fix for AMQ-2075

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java?rev=745480&r1=745479&r2=745480&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java
Wed Feb 18 11:43:29 2009
@@ -1128,6 +1128,9 @@
             connection1.send(createAck(consumerInfo1, m1, 1, MessageAck.STANDARD_ACK_TYPE));
         }
 
+        // give the async ack a chance to perculate and validate all are currently consumed
+        assertNull(connection1.getDispatchQueue().poll(MAX_NULL_WAIT, TimeUnit.MILLISECONDS));
+
         // Close the connection, this should in turn close the consumer.
         connection1.request(closeConnectionInfo(connectionInfo1));
 



Mime
View raw message