From 7f5e6667f4b2e281bd7a6011a8054775f2b4dbc3 Mon Sep 17 00:00:00 2001 From: Gary Tully Date: Wed, 18 Feb 2009 11:43:29 +0000 Subject: [PATCH] partial fix for AMQ-2075 git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@745480 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/test/java/org/apache/activemq/broker/BrokerTest.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java b/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java index 332b5526c7..1742e2144e 100755 --- a/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java @@ -1128,6 +1128,9 @@ public class BrokerTest extends BrokerTestSupport { 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));