You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2018/10/18 09:32:57 UTC
activemq git commit: no jira - give test a second bite to avoid
spurious timing related failures in ci
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 <ga...@gmail.com>
Authored: Thu Oct 18 10:32:33 2018 +0100
Committer: gtully <ga...@gmail.com>
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();