Consistent support for setStartTime in CronTrigger(Factory)Bean and SimpleTrigger(Factory)Bean, and consistent declaration of varargs in scheduling.quartz package

Issue: SPR-10940
(cherry picked from commit b228a06)
This commit is contained in:
Juergen Hoeller 2014-01-05 17:30:42 +01:00
parent c2459b4a61
commit ab6c6b104d
8 changed files with 70 additions and 53 deletions

View File

@ -73,7 +73,7 @@ public class CronTriggerBean extends CronTrigger
private String beanName; private String beanName;
private long startDelay; private long startDelay = 0;
/** /**
@ -108,9 +108,9 @@ public class CronTriggerBean extends CronTrigger
* @see SchedulerFactoryBean#setTriggerListeners * @see SchedulerFactoryBean#setTriggerListeners
* @see org.quartz.TriggerListener#getName * @see org.quartz.TriggerListener#getName
*/ */
public void setTriggerListenerNames(String[] names) { public void setTriggerListenerNames(String... names) {
for (int i = 0; i < names.length; i++) { for (String name : names) {
addTriggerListener(names[i]); addTriggerListener(name);
} }
} }
@ -148,19 +148,19 @@ public class CronTriggerBean extends CronTrigger
} }
/**
* Note that this method's declaration of an Exception is deprecated
* and will be removed in the Spring 4.0 line.
*/
public void afterPropertiesSet() throws Exception { public void afterPropertiesSet() throws Exception {
if (this.startDelay > 0) {
setStartTime(new Date(System.currentTimeMillis() + this.startDelay));
}
if (getName() == null) { if (getName() == null) {
setName(this.beanName); setName(this.beanName);
} }
if (getGroup() == null) { if (getGroup() == null) {
setGroup(Scheduler.DEFAULT_GROUP); setGroup(Scheduler.DEFAULT_GROUP);
} }
if (getStartTime() == null) { if (this.startDelay > 0 || getStartTime() == null) {
setStartTime(new Date()); setStartTime(new Date(System.currentTimeMillis() + this.startDelay));
} }
if (getTimeZone() == null) { if (getTimeZone() == null) {
setTimeZone(TimeZone.getDefault()); setTimeZone(TimeZone.getDefault());

View File

@ -78,7 +78,7 @@ public class CronTriggerFactoryBean implements FactoryBean<CronTrigger>, BeanNam
private Date startTime; private Date startTime;
private long startDelay; private long startDelay = 0;
private String cronExpression; private String cronExpression;
@ -141,6 +141,15 @@ public class CronTriggerFactoryBean implements FactoryBean<CronTrigger>, BeanNam
this.jobDataMap.putAll(jobDataAsMap); this.jobDataMap.putAll(jobDataAsMap);
} }
/**
* Set a specific start time for the trigger.
* <p>Note that a dynamically computed {@link #setStartDelay} specification
* overrides a static timestamp set here.
*/
public void setStartTime(Date startTime) {
this.startTime = startTime;
}
/** /**
* Set the start delay in milliseconds. * Set the start delay in milliseconds.
* <p>The start delay is added to the current system time (when the bean starts) * <p>The start delay is added to the current system time (when the bean starts)
@ -206,12 +215,9 @@ public class CronTriggerFactoryBean implements FactoryBean<CronTrigger>, BeanNam
if (this.jobDetail != null) { if (this.jobDetail != null) {
this.jobDataMap.put(JobDetailAwareTrigger.JOB_DETAIL_KEY, this.jobDetail); this.jobDataMap.put(JobDetailAwareTrigger.JOB_DETAIL_KEY, this.jobDetail);
} }
if (this.startDelay > 0) { if (this.startDelay > 0 || this.startTime == null) {
this.startTime = new Date(System.currentTimeMillis() + this.startDelay); this.startTime = new Date(System.currentTimeMillis() + this.startDelay);
} }
else if (this.startTime == null) {
this.startTime = new Date();
}
if (this.timeZone == null) { if (this.timeZone == null) {
this.timeZone = TimeZone.getDefault(); this.timeZone = TimeZone.getDefault();
} }

View File

@ -48,11 +48,11 @@ import org.springframework.context.ApplicationContextAware;
* @see org.springframework.beans.factory.BeanNameAware * @see org.springframework.beans.factory.BeanNameAware
* @see org.quartz.Scheduler#DEFAULT_GROUP * @see org.quartz.Scheduler#DEFAULT_GROUP
*/ */
@SuppressWarnings("serial") @SuppressWarnings({"serial", "rawtypes"})
public class JobDetailBean extends JobDetail public class JobDetailBean extends JobDetail
implements BeanNameAware, ApplicationContextAware, InitializingBean { implements BeanNameAware, ApplicationContextAware, InitializingBean {
private Class actualJobClass; private Class<?> actualJobClass;
private String beanName; private String beanName;
@ -82,7 +82,7 @@ public class JobDetailBean extends JobDetail
* to adapt the given job class to the Quartz Job interface. * to adapt the given job class to the Quartz Job interface.
*/ */
@Override @Override
public Class getJobClass() { public Class<?> getJobClass() {
return (this.actualJobClass != null ? this.actualJobClass : super.getJobClass()); return (this.actualJobClass != null ? this.actualJobClass : super.getJobClass());
} }
@ -109,9 +109,9 @@ public class JobDetailBean extends JobDetail
* @see SchedulerFactoryBean#setJobListeners * @see SchedulerFactoryBean#setJobListeners
* @see org.quartz.JobListener#getName * @see org.quartz.JobListener#getName
*/ */
public void setJobListenerNames(String[] names) { public void setJobListenerNames(String... names) {
for (int i = 0; i < names.length; i++) { for (String name : names) {
addJobListener(names[i]); addJobListener(name);
} }
} }

View File

@ -92,7 +92,7 @@ public class MethodInvokingJobDetailFactoryBean extends ArgumentConvertingMethod
jobDetailImplClass = null; jobDetailImplClass = null;
} }
try { try {
Class jobExecutionContextClass = Class<?> jobExecutionContextClass =
QuartzJobBean.class.getClassLoader().loadClass("org.quartz.JobExecutionContext"); QuartzJobBean.class.getClassLoader().loadClass("org.quartz.JobExecutionContext");
setResultMethod = jobExecutionContextClass.getMethod("setResult", Object.class); setResultMethod = jobExecutionContextClass.getMethod("setResult", Object.class);
} }
@ -172,7 +172,7 @@ public class MethodInvokingJobDetailFactoryBean extends ArgumentConvertingMethod
* @see SchedulerFactoryBean#setJobListeners * @see SchedulerFactoryBean#setJobListeners
* @see org.quartz.JobListener#getName * @see org.quartz.JobListener#getName
*/ */
public void setJobListenerNames(String[] names) { public void setJobListenerNames(String... names) {
this.jobListenerNames = names; this.jobListenerNames = names;
} }
@ -189,7 +189,7 @@ public class MethodInvokingJobDetailFactoryBean extends ArgumentConvertingMethod
} }
@Override @Override
protected Class resolveClassName(String className) throws ClassNotFoundException { protected Class<?> resolveClassName(String className) throws ClassNotFoundException {
return ClassUtils.forName(className, this.beanClassLoader); return ClassUtils.forName(className, this.beanClassLoader);
} }
@ -201,7 +201,7 @@ public class MethodInvokingJobDetailFactoryBean extends ArgumentConvertingMethod
String name = (this.name != null ? this.name : this.beanName); String name = (this.name != null ? this.name : this.beanName);
// Consider the concurrent flag to choose between stateful and stateless job. // Consider the concurrent flag to choose between stateful and stateless job.
Class jobClass = (this.concurrent ? MethodInvokingJob.class : StatefulMethodInvokingJob.class); Class<?> jobClass = (this.concurrent ? MethodInvokingJob.class : StatefulMethodInvokingJob.class);
// Build JobDetail instance. // Build JobDetail instance.
if (jobDetailImplClass != null) { if (jobDetailImplClass != null) {
@ -249,8 +249,8 @@ public class MethodInvokingJobDetailFactoryBean extends ArgumentConvertingMethod
* Overridden to support the {@link #setTargetBeanName "targetBeanName"} feature. * Overridden to support the {@link #setTargetBeanName "targetBeanName"} feature.
*/ */
@Override @Override
public Class getTargetClass() { public Class<?> getTargetClass() {
Class targetClass = super.getTargetClass(); Class<?> targetClass = super.getTargetClass();
if (targetClass == null && this.targetBeanName != null) { if (targetClass == null && this.targetBeanName != null) {
Assert.state(this.beanFactory != null, "BeanFactory must be set when using 'targetBeanName'"); Assert.state(this.beanFactory != null, "BeanFactory must be set when using 'targetBeanName'");
targetClass = this.beanFactory.getType(this.targetBeanName); targetClass = this.beanFactory.getType(this.targetBeanName);

View File

@ -128,7 +128,7 @@ public abstract class SchedulerAccessor implements ResourceLoaderAware {
* to jobs defined directly on this SchedulerFactoryBean. * to jobs defined directly on this SchedulerFactoryBean.
* @see org.quartz.xml.XmlSchedulingDataProcessor * @see org.quartz.xml.XmlSchedulingDataProcessor
*/ */
public void setJobSchedulingDataLocations(String[] jobSchedulingDataLocations) { public void setJobSchedulingDataLocations(String... jobSchedulingDataLocations) {
this.jobSchedulingDataLocations = jobSchedulingDataLocations; this.jobSchedulingDataLocations = jobSchedulingDataLocations;
} }
@ -142,9 +142,8 @@ public abstract class SchedulerAccessor implements ResourceLoaderAware {
* @see org.quartz.JobDetail * @see org.quartz.JobDetail
* @see JobDetailBean * @see JobDetailBean
* @see JobDetailAwareTrigger * @see JobDetailAwareTrigger
* @see org.quartz.Trigger#setJobName
*/ */
public void setJobDetails(JobDetail[] jobDetails) { public void setJobDetails(JobDetail... jobDetails) {
// Use modifiable ArrayList here, to allow for further adding of // Use modifiable ArrayList here, to allow for further adding of
// JobDetail objects during autodetection of JobDetailAwareTriggers. // JobDetail objects during autodetection of JobDetailAwareTriggers.
this.jobDetails = new ArrayList<JobDetail>(Arrays.asList(jobDetails)); this.jobDetails = new ArrayList<JobDetail>(Arrays.asList(jobDetails));
@ -156,7 +155,6 @@ public abstract class SchedulerAccessor implements ResourceLoaderAware {
* @param calendars Map with calendar names as keys as Calendar * @param calendars Map with calendar names as keys as Calendar
* objects as values * objects as values
* @see org.quartz.Calendar * @see org.quartz.Calendar
* @see org.quartz.Trigger#setCalendarName
*/ */
public void setCalendars(Map<String, Calendar> calendars) { public void setCalendars(Map<String, Calendar> calendars) {
this.calendars = calendars; this.calendars = calendars;
@ -175,7 +173,7 @@ public abstract class SchedulerAccessor implements ResourceLoaderAware {
* @see CronTriggerBean * @see CronTriggerBean
* @see SimpleTriggerBean * @see SimpleTriggerBean
*/ */
public void setTriggers(Trigger[] triggers) { public void setTriggers(Trigger... triggers) {
this.triggers = Arrays.asList(triggers); this.triggers = Arrays.asList(triggers);
} }
@ -183,7 +181,7 @@ public abstract class SchedulerAccessor implements ResourceLoaderAware {
/** /**
* Specify Quartz SchedulerListeners to be registered with the Scheduler. * Specify Quartz SchedulerListeners to be registered with the Scheduler.
*/ */
public void setSchedulerListeners(SchedulerListener[] schedulerListeners) { public void setSchedulerListeners(SchedulerListener... schedulerListeners) {
this.schedulerListeners = schedulerListeners; this.schedulerListeners = schedulerListeners;
} }
@ -191,7 +189,7 @@ public abstract class SchedulerAccessor implements ResourceLoaderAware {
* Specify global Quartz JobListeners to be registered with the Scheduler. * Specify global Quartz JobListeners to be registered with the Scheduler.
* Such JobListeners will apply to all Jobs in the Scheduler. * Such JobListeners will apply to all Jobs in the Scheduler.
*/ */
public void setGlobalJobListeners(JobListener[] globalJobListeners) { public void setGlobalJobListeners(JobListener... globalJobListeners) {
this.globalJobListeners = globalJobListeners; this.globalJobListeners = globalJobListeners;
} }
@ -199,11 +197,12 @@ public abstract class SchedulerAccessor implements ResourceLoaderAware {
* Specify named Quartz JobListeners to be registered with the Scheduler. * Specify named Quartz JobListeners to be registered with the Scheduler.
* Such JobListeners will only apply to Jobs that explicitly activate * Such JobListeners will only apply to Jobs that explicitly activate
* them via their name. * them via their name.
* <p>Note that non-global JobListeners are not supported on Quartz 2.x -
* manually register a Matcher against the Quartz ListenerManager instead.
* @see org.quartz.JobListener#getName * @see org.quartz.JobListener#getName
* @see org.quartz.JobDetail#addJobListener
* @see JobDetailBean#setJobListenerNames * @see JobDetailBean#setJobListenerNames
*/ */
public void setJobListeners(JobListener[] jobListeners) { public void setJobListeners(JobListener... jobListeners) {
this.jobListeners = jobListeners; this.jobListeners = jobListeners;
} }
@ -211,7 +210,7 @@ public abstract class SchedulerAccessor implements ResourceLoaderAware {
* Specify global Quartz TriggerListeners to be registered with the Scheduler. * Specify global Quartz TriggerListeners to be registered with the Scheduler.
* Such TriggerListeners will apply to all Triggers in the Scheduler. * Such TriggerListeners will apply to all Triggers in the Scheduler.
*/ */
public void setGlobalTriggerListeners(TriggerListener[] globalTriggerListeners) { public void setGlobalTriggerListeners(TriggerListener... globalTriggerListeners) {
this.globalTriggerListeners = globalTriggerListeners; this.globalTriggerListeners = globalTriggerListeners;
} }
@ -219,12 +218,13 @@ public abstract class SchedulerAccessor implements ResourceLoaderAware {
* Specify named Quartz TriggerListeners to be registered with the Scheduler. * Specify named Quartz TriggerListeners to be registered with the Scheduler.
* Such TriggerListeners will only apply to Triggers that explicitly activate * Such TriggerListeners will only apply to Triggers that explicitly activate
* them via their name. * them via their name.
* <p>Note that non-global TriggerListeners are not supported on Quartz 2.x -
* manually register a Matcher against the Quartz ListenerManager instead.
* @see org.quartz.TriggerListener#getName * @see org.quartz.TriggerListener#getName
* @see org.quartz.Trigger#addTriggerListener
* @see CronTriggerBean#setTriggerListenerNames * @see CronTriggerBean#setTriggerListenerNames
* @see SimpleTriggerBean#setTriggerListenerNames * @see SimpleTriggerBean#setTriggerListenerNames
*/ */
public void setTriggerListeners(TriggerListener[] triggerListeners) { public void setTriggerListeners(TriggerListener... triggerListeners) {
this.triggerListeners = triggerListeners; this.triggerListeners = triggerListeners;
} }
@ -251,8 +251,8 @@ public abstract class SchedulerAccessor implements ResourceLoaderAware {
if (this.transactionManager != null) { if (this.transactionManager != null) {
transactionStatus = this.transactionManager.getTransaction(new DefaultTransactionDefinition()); transactionStatus = this.transactionManager.getTransaction(new DefaultTransactionDefinition());
} }
try {
try {
if (this.jobSchedulingDataLocations != null) { if (this.jobSchedulingDataLocations != null) {
ClassLoadHelper clh = new ResourceLoaderClassLoadHelper(this.resourceLoader); ClassLoadHelper clh = new ResourceLoaderClassLoadHelper(this.resourceLoader);
clh.initialize(); clh.initialize();
@ -396,7 +396,7 @@ public abstract class SchedulerAccessor implements ResourceLoaderAware {
} }
else { else {
try { try {
Map jobDataMap = (Map) ReflectionUtils.invokeMethod(Trigger.class.getMethod("getJobDataMap"), trigger); Map<?, ?> jobDataMap = (Map<?, ?>) ReflectionUtils.invokeMethod(Trigger.class.getMethod("getJobDataMap"), trigger);
return (JobDetail) jobDataMap.remove(JobDetailAwareTrigger.JOB_DETAIL_KEY); return (JobDetail) jobDataMap.remove(JobDetailAwareTrigger.JOB_DETAIL_KEY);
} }
catch (NoSuchMethodException ex) { catch (NoSuchMethodException ex) {

View File

@ -114,9 +114,9 @@ public class SimpleTriggerBean extends SimpleTrigger
* @see SchedulerFactoryBean#setTriggerListeners * @see SchedulerFactoryBean#setTriggerListeners
* @see org.quartz.TriggerListener#getName * @see org.quartz.TriggerListener#getName
*/ */
public void setTriggerListenerNames(String[] names) { public void setTriggerListenerNames(String... names) {
for (int i = 0; i < names.length; i++) { for (String name : names) {
addTriggerListener(names[i]); addTriggerListener(name);
} }
} }
@ -153,6 +153,10 @@ public class SimpleTriggerBean extends SimpleTrigger
} }
/**
* Note that this method's declaration of a ParseException is deprecated
* and will be removed in the Spring 4.0 line.
*/
public void afterPropertiesSet() throws ParseException { public void afterPropertiesSet() throws ParseException {
if (getName() == null) { if (getName() == null) {
setName(this.beanName); setName(this.beanName);
@ -160,7 +164,7 @@ public class SimpleTriggerBean extends SimpleTrigger
if (getGroup() == null) { if (getGroup() == null) {
setGroup(Scheduler.DEFAULT_GROUP); setGroup(Scheduler.DEFAULT_GROUP);
} }
if (getStartTime() == null) { if (this.startDelay > 0 || getStartTime() == null) {
setStartTime(new Date(System.currentTimeMillis() + this.startDelay)); setStartTime(new Date(System.currentTimeMillis() + this.startDelay));
} }
if (this.jobDetail != null) { if (this.jobDetail != null) {

View File

@ -17,7 +17,6 @@
package org.springframework.scheduling.quartz; package org.springframework.scheduling.quartz;
import java.lang.reflect.Method; import java.lang.reflect.Method;
import java.text.ParseException;
import java.util.Date; import java.util.Date;
import java.util.Map; import java.util.Map;
@ -141,10 +140,20 @@ public class SimpleTriggerFactoryBean implements FactoryBean<SimpleTrigger>, Bea
this.jobDataMap.putAll(jobDataAsMap); this.jobDataMap.putAll(jobDataAsMap);
} }
/**
* Set a specific start time for the trigger.
* <p>Note that a dynamically computed {@link #setStartDelay} specification
* overrides a static timestamp set here.
*/
public void setStartTime(Date startTime) {
this.startTime = startTime;
}
/** /**
* Set the start delay in milliseconds. * Set the start delay in milliseconds.
* <p>The start delay is added to the current system time (when the bean starts) * <p>The start delay is added to the current system time (when the bean starts)
* to control the start time of the trigger. * to control the start time of the trigger.
* @see #setStartTime
*/ */
public void setStartDelay(long startDelay) { public void setStartDelay(long startDelay) {
Assert.isTrue(startDelay >= 0, "Start delay cannot be negative"); Assert.isTrue(startDelay >= 0, "Start delay cannot be negative");
@ -200,7 +209,7 @@ public class SimpleTriggerFactoryBean implements FactoryBean<SimpleTrigger>, Bea
} }
public void afterPropertiesSet() throws ParseException { public void afterPropertiesSet() {
if (this.name == null) { if (this.name == null) {
this.name = this.beanName; this.name = this.beanName;
} }
@ -210,12 +219,9 @@ public class SimpleTriggerFactoryBean implements FactoryBean<SimpleTrigger>, Bea
if (this.jobDetail != null) { if (this.jobDetail != null) {
this.jobDataMap.put(JobDetailAwareTrigger.JOB_DETAIL_KEY, this.jobDetail); this.jobDataMap.put(JobDetailAwareTrigger.JOB_DETAIL_KEY, this.jobDetail);
} }
if (this.startDelay > 0) { if (this.startDelay > 0 || this.startTime == null) {
this.startTime = new Date(System.currentTimeMillis() + this.startDelay); this.startTime = new Date(System.currentTimeMillis() + this.startDelay);
} }
else if (this.startTime == null) {
this.startTime = new Date();
}
/* /*
SimpleTriggerImpl sti = new SimpleTriggerImpl(); SimpleTriggerImpl sti = new SimpleTriggerImpl();
@ -231,7 +237,7 @@ public class SimpleTriggerFactoryBean implements FactoryBean<SimpleTrigger>, Bea
this.simpleTrigger = sti; this.simpleTrigger = sti;
*/ */
Class simpleTriggerClass; Class<?> simpleTriggerClass;
Method jobKeyMethod; Method jobKeyMethod;
try { try {
simpleTriggerClass = getClass().getClassLoader().loadClass("org.quartz.impl.triggers.SimpleTriggerImpl"); simpleTriggerClass = getClass().getClassLoader().loadClass("org.quartz.impl.triggers.SimpleTriggerImpl");
@ -277,4 +283,5 @@ public class SimpleTriggerFactoryBean implements FactoryBean<SimpleTrigger>, Bea
public boolean isSingleton() { public boolean isSingleton() {
return true; return true;
} }
} }

View File

@ -59,7 +59,7 @@ public class SpringBeanJobFactory extends AdaptableJobFactory implements Schedul
* ignored if there is no corresponding property found on the particular * ignored if there is no corresponding property found on the particular
* job class (all other unknown properties will still trigger an exception). * job class (all other unknown properties will still trigger an exception).
*/ */
public void setIgnoredUnknownProperties(String[] ignoredUnknownProperties) { public void setIgnoredUnknownProperties(String... ignoredUnknownProperties) {
this.ignoredUnknownProperties = ignoredUnknownProperties; this.ignoredUnknownProperties = ignoredUnknownProperties;
} }