Changed misfire policy

This commit is contained in:
fabio.formosa
2016-06-22 13:09:47 +02:00
parent 9f88bfc2cd
commit 39292adc7d

View File

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