本文整理了Java中org.quartz.CronTrigger.getJobKey()
方法的一些代码示例,展示了CronTrigger.getJobKey()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。CronTrigger.getJobKey()
方法的具体详情如下:
包路径:org.quartz.CronTrigger
类名称:CronTrigger
方法名:getJobKey
暂无
代码示例来源:origin: quartz-scheduler/quartz
public static CompositeData toCompositeData(CronTrigger trigger) {
try {
return new CompositeDataSupport(COMPOSITE_TYPE, ITEM_NAMES,
new Object[] {
trigger.getCronExpression(),
trigger.getTimeZone(),
trigger.getKey().getName(),
trigger.getKey().getGroup(),
trigger.getJobKey().getName(),
trigger.getJobKey().getGroup(),
trigger.getDescription(),
JobDataMapSupport.toTabularData(trigger
.getJobDataMap()),
trigger.getCalendarName(),
((OperableTrigger)trigger).getFireInstanceId(),
trigger.getMisfireInstruction(),
trigger.getPriority(), trigger.getStartTime(),
trigger.getEndTime(), trigger.getNextFireTime(),
trigger.getPreviousFireTime(),
trigger.getFinalFireTime() });
} catch (OpenDataException e) {
throw new RuntimeException(e);
}
}
代码示例来源:origin: xautlx/s2jh4net
@Override
public void delete(JobBeanCfg entity) {
try {
Map<Trigger, SchedulerFactoryBean> allTriggers = findAllTriggers();
for (Map.Entry<Trigger, SchedulerFactoryBean> me : allTriggers.entrySet()) {
CronTrigger cronTrigger = (CronTrigger) me.getKey();
ExtSchedulerFactoryBean schedulerFactoryBean = (ExtSchedulerFactoryBean) me.getValue();
Scheduler scheduler = schedulerFactoryBean.getScheduler();
if (cronTrigger.getJobKey().getName().equals(entity.getJobClass())) {
logger.info("UnscheduleJob from quartzClusterScheduler: {}", cronTrigger.getJobKey());
scheduler.unscheduleJob(cronTrigger.getKey());
break;
}
}
} catch (Exception e) {
throw new ServiceException("Quartz trigger schedule error", e);
}
super.delete(entity);
}
代码示例来源:origin: xautlx/s2jh4net
@Override
public JobBeanCfg save(JobBeanCfg entity) {
try {
if (!entity.isNew()) {// 新配置任务不做Schedule处理,需要重新启动应用服务器才能生效
Map<Trigger, SchedulerFactoryBean> allTriggers = findAllTriggers();
for (Map.Entry<Trigger, SchedulerFactoryBean> me : allTriggers.entrySet()) {
CronTrigger cronTrigger = (CronTrigger) me.getKey();
ExtSchedulerFactoryBean schedulerFactoryBean = (ExtSchedulerFactoryBean) me.getValue();
Scheduler scheduler = schedulerFactoryBean.getScheduler();
if (cronTrigger.getJobKey().getName().equals(entity.getJobClass())
&& !entity.getCronExpression().equals(cronTrigger.getCronExpression())) {
CronTrigger newTrigger = TriggerBuilder.newTrigger().withIdentity(cronTrigger.getKey())
.withSchedule(CronScheduleBuilder.cronSchedule(entity.getCronExpression())).build();
String oldCronExpression = cronTrigger.getCronExpression();
logger.info("RescheduleJob : {}, CRON from {} to {}", cronTrigger.getKey(), oldCronExpression,
cronTrigger.getCronExpression());
scheduler.rescheduleJob(newTrigger.getKey(), newTrigger);
break;
}
}
}
} catch (Exception e) {
throw new ServiceException("Quartz trigger schedule error", e);
}
return super.save(entity);
}
代码示例来源:origin: org.motechproject/motech-scheduler
throw new MotechSchedulerException();
job = scheduler.getJobDetail(trigger.getJobKey());
} catch (SchedulerException e) {
handleException(String.format("Can not reschedule the job: %s.\n Can not get a trigger associated with that job %s", jobId, e.getMessage()), e);
代码示例来源:origin: org.apache.camel/camel-quartz2
job = quartzScheduler.getJobDetail(existingTrigger.getJobKey());
JobDataMap jobData = job.getJobDataMap();
jobData.put(QuartzConstants.QUARTZ_TRIGGER_CRON_EXPRESSION, getCron());
代码示例来源:origin: nkcoder/quartz-explained
public static CompositeData toCompositeData(CronTrigger trigger) {
try {
return new CompositeDataSupport(COMPOSITE_TYPE, ITEM_NAMES,
new Object[] {
trigger.getCronExpression(),
trigger.getTimeZone(),
trigger.getKey().getName(),
trigger.getKey().getGroup(),
trigger.getJobKey().getName(),
trigger.getJobKey().getGroup(),
trigger.getDescription(),
JobDataMapSupport.toTabularData(trigger
.getJobDataMap()),
trigger.getCalendarName(),
((OperableTrigger)trigger).getFireInstanceId(),
trigger.getMisfireInstruction(),
trigger.getPriority(), trigger.getStartTime(),
trigger.getEndTime(), trigger.getNextFireTime(),
trigger.getPreviousFireTime(),
trigger.getFinalFireTime() });
} catch (OpenDataException e) {
throw new RuntimeException(e);
}
}
内容来源于网络,如有侵权,请联系作者删除!