public class extends AdaptableJobFactory {
@Autowired
private AutowireCapableBeanFactory capableBeanFactory;
@Override
protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
Object jobInstance = super.createJobInstance(bundle);
capableBeanFactory.autowireBean(jobInstance);
return jobInstance;
}
}
@Configuration
public class QuartzConfig {
...
@Bean
public SchedulerFactoryBean schedulerFactoryBean() throws IOException {
schedulerFactory = new SchedulerFactoryBean();
schedulerFactory.setOverwriteExistingJobs(true);
schedulerFactory.setStartupDelay(20);
schedulerFactory.setQuartzProperties(quartzProperties());
schedulerFactory.setJobFactory(customJobFactory);
return schedulerFactory;
}
}
近期评论