From c093c680c094152b6789d5af1a347b46358bfd33 Mon Sep 17 00:00:00 2001 From: Darin Kelkhoff Date: Thu, 14 Mar 2024 11:33:28 -0500 Subject: [PATCH] Work-around default delay when scheduling, for test --- .../core/scheduler/quartz/QuartzTestUtils.java | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/qqq-backend-core/src/test/java/com/kingsrook/qqq/backend/core/scheduler/quartz/QuartzTestUtils.java b/qqq-backend-core/src/test/java/com/kingsrook/qqq/backend/core/scheduler/quartz/QuartzTestUtils.java index 44ba5437..3e952b50 100644 --- a/qqq-backend-core/src/test/java/com/kingsrook/qqq/backend/core/scheduler/quartz/QuartzTestUtils.java +++ b/qqq-backend-core/src/test/java/com/kingsrook/qqq/backend/core/scheduler/quartz/QuartzTestUtils.java @@ -72,19 +72,25 @@ public class QuartzTestUtils .withProperties(getQuartzProperties()) .withName(QUARTZ_SCHEDULER_NAME)); - //////////////////////////////////////////////////////////////////////////////// - // set the queue providers & automation providers to use the quartz scheduler // - //////////////////////////////////////////////////////////////////////////////// + /////////////////////////////////////////////////////////////////////////////////// + // set the queue providers & automation providers to use the quartz scheduler // + // also, set their initial delay to avoid default delay done by our scheduler // + // (that gives us a chance to re-pause if re-scheduling a previously paused job) // + /////////////////////////////////////////////////////////////////////////////////// qInstance.getTables().values().forEach(t -> { if(t.getAutomationDetails() != null) { - t.getAutomationDetails().getSchedule().setSchedulerName(QUARTZ_SCHEDULER_NAME); + t.getAutomationDetails().getSchedule() + .withSchedulerName(QUARTZ_SCHEDULER_NAME) + .withInitialDelayMillis(1); } }); qInstance.getQueues().values() - .forEach(q -> q.getSchedule().setSchedulerName(QUARTZ_SCHEDULER_NAME)); + .forEach(q -> q.getSchedule() + .withSchedulerName(QUARTZ_SCHEDULER_NAME) + .withInitialDelayMillis(1)); }