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

AMQ-7221 - Fix InMemoryJobSchedulerManagementTest that was broken after 

patch
This commit is contained in:
Christopher L. Shannon (cshannon) 2019-06-14 10:28:57 -04:00
parent 4d5e41ca28
commit 814a286dfe
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/JobSchedulerManagementTest.java
View File

@ -60,8 +60,10 @@ public class JobSchedulerManagementTest extends JobSchedulerTestSupport {
@Override
protected BrokerService createBroker() throws Exception {
BrokerService brokerService = createBroker(true);
((JobSchedulerStoreImpl) brokerService.getJobSchedulerStore()).setCleanupInterval(500);
((JobSchedulerStoreImpl) brokerService.getJobSchedulerStore()).setJournalMaxFileLength(100* 1024);
if (isPersistent()) {
((JobSchedulerStoreImpl) brokerService.getJobSchedulerStore()).setCleanupInterval(500);
((JobSchedulerStoreImpl) brokerService.getJobSchedulerStore()).setJournalMaxFileLength(100 * 1024);
}
return brokerService;
}
@ -102,7 +104,10 @@ public class JobSchedulerManagementTest extends JobSchedulerTestSupport {
// Now wait and see if any get delivered, none should.
latch.await(10, TimeUnit.SECONDS);
assertEquals(latch.getCount(), COUNT);
assertEquals(1, getNumberOfJournalFiles());
if (isPersistent()) {
assertEquals(1, getNumberOfJournalFiles());
}
connection.close();
}