You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cs...@apache.org on 2019/06/14 14:34:40 UTC
[activemq] 01/04: AMQ-7221 - Fix InMemoryJobSchedulerManagementTest
that was broken after patch
This is an automated email from the ASF dual-hosted git repository.
cshannon pushed a commit to branch activemq-5.15.x
in repository https://gitbox.apache.org/repos/asf/activemq.git
commit 8f8fda26ec5a0e1da1a59e1f87361dee1682b9e8
Author: Christopher L. Shannon (cshannon) <ch...@gmail.com>
AuthorDate: Fri Jun 14 10:28:57 2019 -0400
AMQ-7221 - Fix InMemoryJobSchedulerManagementTest that was broken after
patch
(cherry picked from commit 814a286dfe64bfde749e54b8552b5197abe97b37)
---
.../activemq/broker/scheduler/JobSchedulerManagementTest.java | 11 ++++++++---
1 file changed, 8 insertions(+), 3 deletions(-)
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/JobSchedulerManagementTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/JobSchedulerManagementTest.java
index 5d80c05..b1f3b2e 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/JobSchedulerManagementTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/JobSchedulerManagementTest.java
@@ -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();
}