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 2016/05/25 11:45:32 UTC
activemq git commit: longer receive timeout on first message,
intermittent ci failure
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 <ga...@gmail.com>
Authored: Wed May 25 12:45:07 2016 +0100
Committer: gtully <ga...@gmail.com>
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();