石英调度程序缺少工作

Question

我正在向 quartz 调度程序添加作业。之后我调用附加的调试打印作业函数。它没有列出工作。对 getCurrentlyExecutingJobs() 的函数调用是否可能限制为最大 return。 10 个职位？

public void scheduleManagementEmail(ManagementEmailConfig managementEmailConfig, Scheduler scheduler) throws SchedulerException
{
    logger.debug("Scheduling Management Email " + 
    managementEmailConfig.getManagementEmailConfigId());

    String jobKey = "SendManagementEmailJob_" +     
    managementEmailConfig.getManagementEmailConfigId();
    Class<? extends Job> jobClass = SendManagementEmailJob.class;
    JobDetail job = JobBuilder.newJob(jobClass).withIdentity(new JobKey(jobKey)).build();
    Trigger trigger = sendManagementEmailJob.getTriggerWithSchedule(managementEmailConfig);
    trigger.getJobDataMap().put("managementEmailConfigId", managementEmailConfig.getManagementEmailConfigId());
    if (!scheduler.checkExists(new JobKey(jobKey)))
    {
        scheduler.scheduleJob(job, trigger);
    }
    debugPrintJobs();
}

public void debugPrintJobs() {
    try {
        logger.debug("Quartz Jobs");
        Scheduler s_scheduler = this.getJobScheduler();
        List<JobExecutionContext> currentJobs = s_scheduler.getCurrentlyExecutingJobs();
    for (JobExecutionContext jobCtx : currentJobs) {
        JobKey jobKey = jobCtx.getJobDetail().getKey();             
        JobDetail jobDetail = s_scheduler.getJobDetail(jobKey);
        List<? extends Trigger> triggers = s_scheduler.getTriggersOfJob(jobKey);

        Date nextFireTime = null;
        if (triggers.size() > 0)
        {
            nextFireTime = triggers.get(0).getNextFireTime();
        }
        logger.debug("Name= "+ jobKey.getName() + " Group=" + jobKey.getGroup() + " NextFireTime=" + nextFireTime); 
    }
} catch (Exception e) {
    logger.debug("debugPrintJobs:" + e.getMessage());
}

Answer 1

方法 getCurrentlyExecutingJobs() 将仅 return 作业运行，而不是每个计划的作业。
要获得每一个预定的工作，你应该这样做：

    Scheduler scheduler = getScheduler();
    try {
        // All scheduled jobs
        for (String groupName : scheduler.getJobGroupNames()) {
            for (JobKey jobKey : scheduler.getJobKeys(GroupMatcher.jobGroupEquals(groupName))) {
                JobDetail jobDetail = scheduler.getJobDetail(jobKey);
                final List<? extends Trigger> triggersOfJob = scheduler.getTriggersOfJob(jobKey);
                // Do something with the info you just got
                // ...
            }
        }
    } catch (SchedulerException e) {
        log.error("Retrieving jobs", e);
    }

石英调度程序缺少工作

Quartz scheduler missing job

java

quartz-scheduler