石英调度程序丢失作业

我正在向石英调度程序添加作业。之后，我打电话给附加的调试打印作业功能。它没有列出工作。对getCurrentlyExecutingJobs()的函数调用可能仅限于返回最大值。 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()); 
}

来源

2016-11-16 Adder

“我增加了作业调度石英。”不在您向我们展示的代码中。 – 2016-11-16 08:29:13

你能否改进你的代码的缩进？这是非常难以阅读。 – 2016-11-16 08:39:29

方法getCurrentlyExecutingJobs()将只返回正在运行的作业，而不是每个计划作业。
让每一个计划的作业，你应该做这样的事情：

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); 
    }

来源

2016-11-16 08:40:39 walen

石英调度程序丢失作业

回答

相关问题