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 <[email protected]> Authored: Tue May 24 10:47:34 2016 +0100 Committer: gtully <[email protected]> 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);
