From 39292adc7d7deec63567017be573f6f864669e4b Mon Sep 17 00:00:00 2001 From: "fabio.formosa" Date: Wed, 22 Jun 2016 13:09:47 +0200 Subject: [PATCH] Changed misfire policy --- .../configuration/SchedulerConfig.java | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/quartz-manager/src/main/java/it/fabioformosa/quartzmanager/configuration/SchedulerConfig.java b/quartz-manager/src/main/java/it/fabioformosa/quartzmanager/configuration/SchedulerConfig.java index 432ab03..c7338dd 100644 --- a/quartz-manager/src/main/java/it/fabioformosa/quartzmanager/configuration/SchedulerConfig.java +++ b/quartz-manager/src/main/java/it/fabioformosa/quartzmanager/configuration/SchedulerConfig.java @@ -1,12 +1,10 @@ package it.fabioformosa.quartzmanager.configuration; -import it.fabioformosa.quartzmanager.jobs.SampleJob; -import it.fabioformosa.quartzmanager.scheduler.AutowiringSpringBeanJobFactory; - import java.io.IOException; import java.util.Properties; import org.quartz.JobDetail; +import org.quartz.SimpleTrigger; import org.quartz.Trigger; import org.quartz.spi.JobFactory; import org.springframework.beans.factory.annotation.Qualifier; @@ -21,6 +19,9 @@ import org.springframework.scheduling.quartz.JobDetailFactoryBean; import org.springframework.scheduling.quartz.SchedulerFactoryBean; import org.springframework.scheduling.quartz.SimpleTriggerFactoryBean; +import it.fabioformosa.quartzmanager.jobs.SampleJob; +import it.fabioformosa.quartzmanager.scheduler.AutowiringSpringBeanJobFactory; + @Configuration @ConditionalOnProperty(name = "quartz.enabled") public class SchedulerConfig { @@ -39,6 +40,8 @@ public class SchedulerConfig { factoryBean.setStartDelay(0L); factoryBean.setRepeatInterval(pollFrequencyMs); factoryBean.setRepeatCount(repeatCount); + factoryBean.setMisfireInstruction( + SimpleTrigger.MISFIRE_INSTRUCTION_RESCHEDULE_NEXT_WITH_REMAINING_COUNT);// in case of misfire, ignore all missed triggers and continue return factoryBean; } @@ -57,8 +60,8 @@ public class SchedulerConfig { @Bean public Properties quartzProperties() throws IOException { PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean(); - propertiesFactoryBean.setLocation(new ClassPathResource( - "/quartz.properties")); + propertiesFactoryBean + .setLocation(new ClassPathResource("/quartz.properties")); propertiesFactoryBean.afterPropertiesSet(); return propertiesFactoryBean.getObject(); }