/* * Copyright 2002-2011 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.springframework.scheduling.quartz; import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.impl.SchedulerRepository; import org.springframework.beans.factory.BeanFactory; import org.springframework.beans.factory.BeanFactoryAware; import org.springframework.beans.factory.InitializingBean; import org.springframework.beans.factory.ListableBeanFactory; /** * Spring bean-style class for accessing a Quartz Scheduler, i.e. for registering jobs, * triggers and listeners on a given {@link org.quartz.Scheduler} instance. * *
Compatible with Quartz 1.5+ as well as Quartz 2.0, as of Spring 3.1. * * @author Juergen Hoeller * @since 2.5.6 * @see #setScheduler * @see #setSchedulerName */ public class SchedulerAccessorBean extends SchedulerAccessor implements BeanFactoryAware, InitializingBean { private String schedulerName; private Scheduler scheduler; private BeanFactory beanFactory; /** * Specify the Quartz Scheduler to operate on via its scheduler name in the Spring * application context or also in the Quartz {@link org.quartz.impl.SchedulerRepository}. *
Schedulers can be registered in the repository through custom bootstrapping, * e.g. via the {@link org.quartz.impl.StdSchedulerFactory} or * {@link org.quartz.impl.DirectSchedulerFactory} factory classes. * However, in general, it's preferable to use Spring's {@link SchedulerFactoryBean} * which includes the job/trigger/listener capabilities of this accessor as well. */ public void setSchedulerName(String schedulerName) { this.schedulerName = schedulerName; } /** * Specify the Quartz Scheduler instance to operate on. */ public void setScheduler(Scheduler scheduler) { this.scheduler = scheduler; } /** * Return the Quartz Scheduler instance that this accessor operates on. */ @Override public Scheduler getScheduler() { return this.scheduler; } public void setBeanFactory(BeanFactory beanFactory) { this.beanFactory = beanFactory; } public void afterPropertiesSet() throws SchedulerException { if (this.scheduler == null) { if (this.schedulerName != null) { this.scheduler = findScheduler(this.schedulerName); } else { throw new IllegalStateException("No Scheduler specified"); } } registerListeners(); registerJobsAndTriggers(); } protected Scheduler findScheduler(String schedulerName) throws SchedulerException { if (this.beanFactory instanceof ListableBeanFactory) { ListableBeanFactory lbf = (ListableBeanFactory) this.beanFactory; String[] beanNames = lbf.getBeanNamesForType(Scheduler.class); for (int i = 0; i < beanNames.length; i++) { Scheduler schedulerBean = (Scheduler) lbf.getBean(beanNames[i]); if (schedulerName.equals(schedulerBean.getSchedulerName())) { return schedulerBean; } } } Scheduler schedulerInRepo = SchedulerRepository.getInstance().lookup(schedulerName); if (schedulerInRepo == null) { throw new IllegalStateException("No Scheduler named '" + schedulerName + "' found"); } return schedulerInRepo; } }