From 092b89189beb9ac00dbb94d5141d654b979d8543 Mon Sep 17 00:00:00 2001
From: Gary Russell <grussell@vmware.com>
Date: Tue, 15 May 2012 20:41:26 -0400
Subject: [PATCH] AMQP-232 Wait for Shutdown

---
 .../MessageListenerContainerLifecycleIntegrationTests.java    | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerContainerLifecycleIntegrationTests.java b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerContainerLifecycleIntegrationTests.java
index b6e93e61..127dca42 100755
--- a/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerContainerLifecycleIntegrationTests.java
+++ b/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/MessageListenerContainerLifecycleIntegrationTests.java
@@ -210,6 +210,10 @@ public class MessageListenerContainerLifecycleIntegrationTests {
 			container.shutdown();
 		}
 
+		int n = 0;
+		while (n++ < 100 && container.getActiveConsumerCount() > 0) {
+			Thread.sleep(100);
+		}
 		assertEquals(0, container.getActiveConsumerCount());
 		assertNull(template.receiveAndConvert(queue.getName()));