Java 类org.quartz.utils.ClassUtils 实例源码

/**
 * <p>
 * Called by the <class>{@link org.quartz.core.QuartzSchedulerThread}
 * </code> to obtain instances of <code>
 * {@link org.quartz.core.JobRunShell}</code>.
 * </p>
 */
public JobRunShell createJobRunShell(TriggerFiredBundle bundle)
        throws SchedulerException {
    ExecuteInJTATransaction jtaAnnotation = ClassUtils.getAnnotation(bundle.getJobDetail().getJobClass(), ExecuteInJTATransaction.class);
    if(jtaAnnotation == null)
        return new JobRunShell(scheduler, bundle);
    else {
        int timeout = jtaAnnotation.timeout();
        if (timeout >= 0) {
            return new JTAJobRunShell(scheduler, bundle, timeout);
        } else {
            return new JTAJobRunShell(scheduler, bundle);
        }
    }
}

@SuppressWarnings("unchecked")
private boolean isJobConcurrentExectionDisallowed(String jobClassName) {
    boolean jobConcurrentExectionDisallowed = false;
    try {
        Class<Job> jobClass = (Class<Job>) loadHelper.getClassLoader().loadClass(jobClassName);
        jobConcurrentExectionDisallowed = ClassUtils.isAnnotationPresent(jobClass, DisallowConcurrentExecution.class);
    } catch (Exception ex) {
        log.error("could not determine whether class: " + jobClassName + " is JobConcurrentExectionDisallowed annotated");
    }
    return jobConcurrentExectionDisallowed;
}

@SuppressWarnings("unchecked")
private boolean isPersistJobDataAfterExecution(String jobClassName) {
    boolean persistJobDataAfterExecution = false;
    try {
        Class<Job> jobClass = (Class<Job>) loadHelper.getClassLoader().loadClass(jobClassName);
        persistJobDataAfterExecution = ClassUtils.isAnnotationPresent(jobClass, PersistJobDataAfterExecution.class);
    } catch (Exception ex) {
        log.error("could not determine whether class: " + jobClassName + " is PersistJobDataAfterExecution annotated");
    }
    return persistJobDataAfterExecution;
}

/**
 * @return whether the associated Job class carries the {@link PersistJobDataAfterExecution} annotation.
 */
public boolean isPersistJobDataAfterExecution() {

    return ClassUtils.isAnnotationPresent(jobClass, PersistJobDataAfterExecution.class);
}

/**
 * @return whether the associated Job class carries the {@link DisallowConcurrentExecution} annotation.
 */
public boolean isConcurrentExectionDisallowed() {

    return ClassUtils.isAnnotationPresent(jobClass, DisallowConcurrentExecution.class);
}

protected boolean isPersistJobDataAfterExecution(Class<? extends Job> jobClass){
    return ClassUtils.isAnnotationPresent(jobClass, PersistJobDataAfterExecution.class);
}

/**
 * Determine if the given job class disallows concurrent execution
 * @param jobClass the job class in question
 * @return true if concurrent execution is NOT allowed; false if concurrent execution IS allowed
 */
protected boolean isJobConcurrentExecutionDisallowed(Class<? extends Job> jobClass){
    return ClassUtils.isAnnotationPresent(jobClass, DisallowConcurrentExecution.class);
}