svn commit: r745480 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java

[gtully]

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));