QRunIO/qqq
2
0
Fork 0
mirror of https://github.com/Kingsrook/qqq.git synced 2025-07-18 13:10:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Work-around default delay when scheduling, for test

Browse Source
This commit is contained in:
darin.kelkhoff
2024-03-14 11:33:28 -05:00
parent aa69f0e7d7
commit c093c680c0
1 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
qqq-backend-core/src/test/java/com/kingsrook/qqq/backend/core/scheduler/quartz/QuartzTestUtils.java
View File

@ -72,19 +72,25 @@ public class QuartzTestUtils
.withProperties(getQuartzProperties()) .withProperties(getQuartzProperties())
.withName(QUARTZ_SCHEDULER_NAME)); .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 -> qInstance.getTables().values().forEach(t ->
{ {
if(t.getAutomationDetails() != null) if(t.getAutomationDetails() != null)
{ {
t.getAutomationDetails().getSchedule().setSchedulerName(QUARTZ_SCHEDULER_NAME); t.getAutomationDetails().getSchedule()
.withSchedulerName(QUARTZ_SCHEDULER_NAME)
.withInitialDelayMillis(1);
} }
}); });
qInstance.getQueues().values() qInstance.getQueues().values()
.forEach(q -> q.getSchedule().setSchedulerName(QUARTZ_SCHEDULER_NAME)); .forEach(q -> q.getSchedule()
.withSchedulerName(QUARTZ_SCHEDULER_NAME)
.withInitialDelayMillis(1));
} }