Repository: activemq Updated Branches: refs/heads/master ed727d22e -> 8690436b5
no jira - give test a second bite to avoid spurious timing related failures in ci Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/8690436b Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/8690436b Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/8690436b Branch: refs/heads/master Commit: 8690436b5b47859a7645d3ef302e5ca9f01880ed Parents: ed727d2 Author: gtully <[email protected]> Authored: Thu Oct 18 10:32:33 2018 +0100 Committer: gtully <[email protected]> Committed: Thu Oct 18 10:32:33 2018 +0100 ---------------------------------------------------------------------- .../usecases/QueueZeroPrefetchLazyDispatchPriorityTest.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/8690436b/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 53e5e33..4764ee9 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 @@ -292,7 +292,11 @@ public class QueueZeroPrefetchLazyDispatchPriorityTest { MessageConsumer consumer = session.createConsumer(new ActiveMQQueue(queueName)); connection.start(); - return consumer.receive(5000); + Message message = consumer.receive(4000); + if (message == null) { + message = consumer.receive(2000); + } + return message; } finally { if (connection != null) { connection.close();
