diff --git a/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java b/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java index 2c4dbcfb37..bd2ee318c5 100755 --- a/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java @@ -91,7 +91,7 @@ public class DurableConsumerTest extends TestCase { consumer = consumerSession.createDurableSubscriber(topic, CONSUMER_NAME); consumerConnection.start(); for (int i =0; i < COUNT;i++) { - Message msg = consumer.receive(1000); + Message msg = consumer.receive(5000); assertNotNull(msg); if (i != 0 && i%1000==0) { LOG.info("Received msg " + i);