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

[no jira] ensure clean db for test AMQ6463Test - intermittent ci failure

This commit is contained in:
gtully 2017-01-16 11:11:45 +00:00
parent 281d600ae2
commit 030c44a554
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6463Test.java
View File

@ -73,12 +73,12 @@ public class AMQ6463Test extends JmsTestSupport {
producer.close();
// lets not consume till producer is blocked
Wait.waitFor(new Wait.Condition() {
assertTrue("got blocked event", Wait.waitFor(new Wait.Condition() {
@Override
public boolean isSatisified() throws Exception {
return gotUsageBlocked.get();
}
});
}));
MessageConsumer consumer = session.createConsumer(queueA);
TextMessage msg;
@ -97,6 +97,7 @@ public class AMQ6463Test extends JmsTestSupport {
service.setPersistent(true);
service.setUseJmx(false);
service.setSchedulerSupport(true);
service.setDeleteAllMessagesOnStartup(true);
// Setup a destination policy where it takes only 1 message at a time.
PolicyMap policyMap = new PolicyMap();