diff --git a/mifosng-provider/src/main/java/org/mifosplatform/infrastructure/jobs/service/JobRegisterServiceImpl.java b/mifosng-provider/src/main/java/org/mifosplatform/infrastructure/jobs/service/JobRegisterServiceImpl.java index 10a40d49d..fe20e40f1 100644 --- a/mifosng-provider/src/main/java/org/mifosplatform/infrastructure/jobs/service/JobRegisterServiceImpl.java +++ b/mifosng-provider/src/main/java/org/mifosplatform/infrastructure/jobs/service/JobRegisterServiceImpl.java @@ -54,6 +54,7 @@ public class JobRegisterServiceImpl implements JobRegisterService { private TenantDetailsService tenantDetailsService; private SchedulerJobListener schedulerJobListener; private SchedulerStopListener schedulerStopListener; + private SchedulerTriggerListener globalSchedulerTriggerListener; private final HashMap schedulers = new HashMap(4); @@ -82,6 +83,11 @@ public class JobRegisterServiceImpl implements JobRegisterService { this.schedulerStopListener = schedulerStopListener; } + @Autowired + public void setGlobalTriggerListener(SchedulerTriggerListener globalTriggerListener) { + this.globalSchedulerTriggerListener = globalTriggerListener; + } + @PostConstruct public void loadAllJobs() { final List allTenants = this.tenantDetailsService.findAllTenants(); @@ -277,8 +283,7 @@ public class JobRegisterServiceImpl implements JobRegisterService { final SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean(); schedulerFactoryBean.setSchedulerName(name); schedulerFactoryBean.setGlobalJobListeners(jobListeners); - final TriggerListener globalTriggerListener = this.applicationContext.getBean("schedulerTriggerListener", TriggerListener.class); - final TriggerListener[] globalTriggerListeners = { globalTriggerListener }; + final TriggerListener[] globalTriggerListeners = { globalSchedulerTriggerListener }; schedulerFactoryBean.setGlobalTriggerListeners(globalTriggerListeners); final Properties quartzProperties = new Properties(); quartzProperties.put(SchedulerFactoryBean.PROP_THREAD_COUNT, Integer.toString(noOfThreads));