From 4df6a20f7abff3120dcd49ed258a8534d8fd88b9 Mon Sep 17 00:00:00 2001 From: Chris Schwarzfischer Date: Mon, 25 Jul 2022 12:37:36 +0200 Subject: [PATCH] fixing #68 --- .../java/net/joelinn/quartz/jobstore/RedisClusterStorage.java | 2 +- src/main/java/net/joelinn/quartz/jobstore/RedisStorage.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/net/joelinn/quartz/jobstore/RedisClusterStorage.java b/src/main/java/net/joelinn/quartz/jobstore/RedisClusterStorage.java index 6ba265b..1524b29 100644 --- a/src/main/java/net/joelinn/quartz/jobstore/RedisClusterStorage.java +++ b/src/main/java/net/joelinn/quartz/jobstore/RedisClusterStorage.java @@ -660,7 +660,7 @@ public List triggersFired(List triggers, Je trigger.triggered(calendar); JobDetail job = retrieveJob(trigger.getJobKey(), jedis); - TriggerFiredBundle triggerFiredBundle = new TriggerFiredBundle(job, trigger, calendar, false, new Date(), previousFireTime, previousFireTime, trigger.getNextFireTime()); + TriggerFiredBundle triggerFiredBundle = new TriggerFiredBundle(job, trigger, calendar, false, new Date(), trigger.getPreviousFireTime(), previousFireTime, trigger.getNextFireTime()); // handling jobs for which concurrent execution is disallowed if (isJobConcurrentExecutionDisallowed(job.getJobClass())) { diff --git a/src/main/java/net/joelinn/quartz/jobstore/RedisStorage.java b/src/main/java/net/joelinn/quartz/jobstore/RedisStorage.java index d6b079b..603c3ca 100644 --- a/src/main/java/net/joelinn/quartz/jobstore/RedisStorage.java +++ b/src/main/java/net/joelinn/quartz/jobstore/RedisStorage.java @@ -707,7 +707,7 @@ public List triggersFired(List triggers, Je } JobDetail job = retrieveJob(trigger.getJobKey(), jedis); - TriggerFiredBundle triggerFiredBundle = new TriggerFiredBundle(job, trigger, calendar, false, new Date(), previousFireTime, previousFireTime, nextFireDate); + TriggerFiredBundle triggerFiredBundle = new TriggerFiredBundle(job, trigger, calendar, false, new Date(), trigger.getPreviousFireTime(), previousFireTime, nextFireDate); // handling jobs for which concurrent execution is disallowed if (isJobConcurrentExecutionDisallowed(job.getJobClass())){