Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix intermittent ci failure - ensure no expiry before first dispatch

This commit is contained in:
gtully 2016-05-24 10:47:34 +01:00
parent 4d6cc4b460
commit f46b2927a4
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ5914Test.java
View File

@ -78,7 +78,7 @@ public class AMQ5914Test {
MessageProducer producer = session.createProducer(queue); MessageProducer producer = session.createProducer(queue);
TextMessage expiredMessage = session.createTextMessage("expired message"); TextMessage expiredMessage = session.createTextMessage("expired message");
TextMessage validMessage = session.createTextMessage("valid 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); producer.send(validMessage);
session.close(); session.close();
@ -91,7 +91,7 @@ public class AMQ5914Test {
// Rollback allow the first message to expire. // Rollback allow the first message to expire.
session.rollback(); session.rollback();
Thread.sleep(75); Thread.sleep(1500);
// Consume again, this should fetch the second valid message via a pull. // Consume again, this should fetch the second valid message via a pull.
message = consumer.receive(3000); message = consumer.receive(3000);