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/24 09:47:47 UTC
activemq git commit: fix intermittent ci failure - ensure no expiry
before first dispatch
Repository: activemq
Updated Branches:
refs/heads/master 4d6cc4b46 -> f46b2927a
fix intermittent ci failure - ensure no expiry before first dispatch
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/f46b2927
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/f46b2927
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/f46b2927
Branch: refs/heads/master
Commit: f46b2927a4fcbd52fd4d80a7908f7f59428079ae
Parents: 4d6cc4b
Author: gtully <ga...@gmail.com>
Authored: Tue May 24 10:47:34 2016 +0100
Committer: gtully <ga...@gmail.com>
Committed: Tue May 24 10:47:34 2016 +0100
----------------------------------------------------------------------
.../src/test/java/org/apache/activemq/bugs/AMQ5914Test.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/f46b2927/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5914Test.java
----------------------------------------------------------------------
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5914Test.java b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5914Test.java
index 0d5a567..0cc3130 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5914Test.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5914Test.java
@@ -78,7 +78,7 @@ public class AMQ5914Test {
MessageProducer producer = session.createProducer(queue);
TextMessage expiredMessage = session.createTextMessage("expired message");
TextMessage validMessage = session.createTextMessage("valid message");
- producer.send(expiredMessage, Message.DEFAULT_DELIVERY_MODE, Message.DEFAULT_PRIORITY, 50);
+ producer.send(expiredMessage, Message.DEFAULT_DELIVERY_MODE, Message.DEFAULT_PRIORITY, 1000);
producer.send(validMessage);
session.close();
@@ -91,7 +91,7 @@ public class AMQ5914Test {
// Rollback allow the first message to expire.
session.rollback();
- Thread.sleep(75);
+ Thread.sleep(1500);
// Consume again, this should fetch the second valid message via a pull.
message = consumer.receive(3000);