This commit is contained in:
@@ -19,23 +19,7 @@ public class ClusteredSchedulerConfig {
|
||||
|
||||
@Autowired @Qualifier("MONITORING")
|
||||
private DataSourceType monitoringDatasource;
|
||||
|
||||
/*
|
||||
public class AutowiringSpringBeanJobFactory extends SpringBeanJobFactory {
|
||||
@Override
|
||||
protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
|
||||
Object job = super.createJobInstance(bundle);
|
||||
applicationContext.getAutowireCapableBeanFactory().autowireBean(job);
|
||||
return job;
|
||||
}
|
||||
}
|
||||
|
||||
@Bean
|
||||
public SpringBeanJobFactory springBeanJobFactory() {
|
||||
return new AutowiringSpringBeanJobFactory();
|
||||
}
|
||||
*/
|
||||
|
||||
|
||||
@Bean(name = "clusteredScheduler")
|
||||
public SchedulerFactoryBean clusteredScheduler() {
|
||||
|
||||
@@ -81,11 +65,15 @@ public class ClusteredSchedulerConfig {
|
||||
factory.setQuartzProperties(quartzProperties);
|
||||
factory.setAutoStartup(true);
|
||||
factory.setSchedulerName("EMS_ClusteredScheduler");
|
||||
// factory.setJobFactory(springBeanJobFactory());
|
||||
|
||||
|
||||
AutoWiringSpringBeanJobFactory jobFactory =
|
||||
new AutoWiringSpringBeanJobFactory(applicationContext.getAutowireCapableBeanFactory());
|
||||
jobFactory.setApplicationContext(applicationContext);
|
||||
factory.setJobFactory(jobFactory);
|
||||
|
||||
factory.setApplicationContextSchedulerContextKey("applicationContext");
|
||||
factory.setApplicationContext(applicationContext);
|
||||
|
||||
|
||||
return factory;
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user