From 9f0a673e36e35efb91f3e2c72aaf2055efcbd6d4 Mon Sep 17 00:00:00 2001
From: Gary Tully <gtully@apache.org>
Date: Fri, 17 Feb 2012 11:37:12 +0000
Subject: [PATCH] order is not guarenteed with multiple consumers, just
 validate quantity

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1245408 13f79535-47bb-0310-9956-ffa450edef68
---
 .../activemq/usecases/TwoBrokerQueueSendReceiveTest.java       | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/activemq-core/src/test/java/org/apache/activemq/usecases/TwoBrokerQueueSendReceiveTest.java b/activemq-core/src/test/java/org/apache/activemq/usecases/TwoBrokerQueueSendReceiveTest.java
index d3b4ddde46..6d01da5efa 100644
--- a/activemq-core/src/test/java/org/apache/activemq/usecases/TwoBrokerQueueSendReceiveTest.java
+++ b/activemq-core/src/test/java/org/apache/activemq/usecases/TwoBrokerQueueSendReceiveTest.java
@@ -42,7 +42,8 @@ public class TwoBrokerQueueSendReceiveTest  extends TwoBrokerTopicSendReceiveTes
             onMessage(consumer.receive(10000));
             consumer.close();
         }
-        this.assertMessagesAreReceived();
+        waitForMessagesToBeDelivered();
+        assertEquals("Got all messages", data.length, messages.size());
 
         BrokerService broker = (BrokerService) brokers.get("receiver");
         final DemandForwardingBridgeSupport bridge = (DemandForwardingBridgeSupport) broker.getNetworkConnectors().get(0).activeBridges().toArray()[0];