Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-23 02:27:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

AMQ-7221 - Fix InMemoryJobSchedulerManagementTest that was broken after

Browse Source 
patch

(cherry picked from commit 814a286dfe64bfde749e54b8552b5197abe97b37)
This commit is contained in:
Christopher L. Shannon (cshannon) 2019-06-14 10:28:57 -04:00
parent 34a235b256
commit 8f8fda26ec
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 @Override
protected BrokerService createBroker() throws Exception { protected BrokerService createBroker() throws Exception {
BrokerService brokerService = createBroker(true); BrokerService brokerService = createBroker(true);
((JobSchedulerStoreImpl) brokerService.getJobSchedulerStore()).setCleanupInterval(500); if (isPersistent()) {
((JobSchedulerStoreImpl) brokerService.getJobSchedulerStore()).setJournalMaxFileLength(100* 1024); ((JobSchedulerStoreImpl) brokerService.getJobSchedulerStore()).setCleanupInterval(500);
((JobSchedulerStoreImpl) brokerService.getJobSchedulerStore()).setJournalMaxFileLength(100 * 1024);
}
return brokerService; return brokerService;
} }
@ -102,7 +104,10 @@ public class JobSchedulerManagementTest extends JobSchedulerTestSupport {
// Now wait and see if any get delivered, none should. // Now wait and see if any get delivered, none should.
latch.await(10, TimeUnit.SECONDS); latch.await(10, TimeUnit.SECONDS);
assertEquals(latch.getCount(), COUNT); assertEquals(latch.getCount(), COUNT);
assertEquals(1, getNumberOfJournalFiles());
if (isPersistent()) {
assertEquals(1, getNumberOfJournalFiles());
}
connection.close(); connection.close();
} }