activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject activemq git commit: longer receive timeout on first message, intermittent ci failure
Date Wed, 25 May 2016 11:45:32 GMT
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 <gary.tully@gmail.com>
Authored: Wed May 25 12:45:07 2016 +0100
Committer: gtully <gary.tully@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();


Mime
View raw message