feat(scheduler): add a channel to handle misfired jobs

quartz/scheduler.go

@@ -112,6 +112,12 @@ type StdSchedulerOptions struct {
 	// using a custom implementation of the JobQueue, where operations
 	// may timeout or fail.
 	RetryInterval time.Duration
+
+	// MisfiredChan allows for creating event listeners to handle jobs that
+	// have failed to be executed on time.
+	// A misfire occurs if a job misses its firing time because the scheduler
+	// is down or there are no available workers in the pool to execute the job.
+	MisfiredChan chan ScheduledJob
 }
 
 // Verify StdScheduler satisfies the Scheduler interface.
@@ -471,6 +477,7 @@ func (sched *StdScheduler) executeAndReschedule(ctx context.Context) {
 		case sched.opts.WorkerLimit > 0:
 			select {
 			case sched.dispatch <- scheduled:
+			case sched.opts.MisfiredChan <- scheduled:
 			case <-ctx.Done():
 				return
 			}
@@ -516,7 +523,11 @@ func (sched *StdScheduler) validateJob(job ScheduledJob) (bool, func() (int64, e
 	now := NowNano()
 	if job.NextRunTime() < now-sched.opts.OutdatedThreshold.Nanoseconds() {
 		duration := time.Duration(now - job.NextRunTime())
-		logger.Debugf("Job %s skipped as outdated %s.", job.JobDetail().jobKey, duration)
+		logger.Debugf("Job %s is outdated %s.", job.JobDetail().jobKey, duration)
+		select {
+		case sched.opts.MisfiredChan <- job:
+		default:
+		}
 		return false, func() (int64, error) { return job.Trigger().NextFireTime(now) }
 	} else if job.NextRunTime() > now {
 		logger.Debugf("Job %s is not due to run yet.", job.JobDetail().jobKey)