Repository: activemq Updated Branches: refs/heads/master 281fbb1f9 -> e467f34cc
longer receive timeout on first message, intermittent ci failure Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/e467f34c Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/e467f34c Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/e467f34c Branch: refs/heads/master Commit: e467f34cc1add0dba8f669aa49f1905245266b7c Parents: 281fbb1 Author: gtully <[email protected]> Authored: Wed May 25 12:45:07 2016 +0100 Committer: gtully <[email protected]> Committed: Wed May 25 12:45:07 2016 +0100 ---------------------------------------------------------------------- .../usecases/QueueZeroPrefetchLazyDispatchPriorityTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/e467f34c/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/QueueZeroPrefetchLazyDispatchPriorityTest.java ---------------------------------------------------------------------- diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/QueueZeroPrefetchLazyDispatchPriorityTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/QueueZeroPrefetchLazyDispatchPriorityTest.java index 8f65a3e..53e5e33 100644 --- a/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/QueueZeroPrefetchLazyDispatchPriorityTest.java +++ b/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/QueueZeroPrefetchLazyDispatchPriorityTest.java @@ -261,7 +261,7 @@ public class QueueZeroPrefetchLazyDispatchPriorityTest { boolean finished = false; while (!finished) { - Message message = consumer.receive(1000); + Message message = consumer.receive(returnedMessages.isEmpty() ? 5000 : 1000); if (message == null) { finished = true; } @@ -292,7 +292,7 @@ public class QueueZeroPrefetchLazyDispatchPriorityTest { MessageConsumer consumer = session.createConsumer(new ActiveMQQueue(queueName)); connection.start(); - return consumer.receive(2000); + return consumer.receive(5000); } finally { if (connection != null) { connection.close();
