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