diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/JMSConsumerTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/JMSConsumerTest.java index fac20f3bac..0eff63fe1a 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/JMSConsumerTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/JMSConsumerTest.java @@ -251,6 +251,7 @@ public class JMSConsumerTest extends JmsTestSupport { } final List subscriptions = getDestinationConsumers(broker, destination); + Thread.sleep(1000); assertTrue("prefetch extension..", subscriptions.stream().