Quartz Job Scheduling Framework［翻译］第八章. 使用 Quartz 插件 (第二部分)

  1package org.cavaness.quartzbook.chapter8;
  2
  3import java.io.File;
  4
  5import org.apache.commons.logging.Log;
  6import org.apache.commons.logging.LogFactory;
  7import org.quartz.Scheduler;
  8import org.quartz.SchedulerConfigException;
  9import org.quartz.SchedulerException;
 10import org.quartz.spi.SchedulerPlugin;
 11import org.quartz.xml.JobSchedulingDataProcessor;
 12
 13public class JobLoaderPlugin implements SchedulerPlugin {
 14
 15    private static Log logger =
 16        LogFactory.getLog(JobLoaderPlugin.class);
 17
 18    // The directory to load jobs from
 19    private String jobsDirectory;
 20
 21    // An array of File objects
 22    private File[] jobFiles = null;
 23
 24    private String pluginName;
 25
 26    private Scheduler scheduler;
 27
 28    private boolean validateXML = true;
 29
 30    private boolean validateSchema = true;
 31
 32    public JobLoaderPlugin() {
 33    }
 34
 35    public File[] getJobFiles() {
 36        return jobFiles;
 37    }
 38
 39    public void setJobFiles(File[] jobFiles) {
 40        this.jobFiles = jobFiles;
 41    }
 42
 43    public boolean isValidateSchema() {
 44        return validateSchema;
 45    }
 46
 47    public void setValidateSchema(boolean validatingSchema) {
 48        this.validateSchema = validatingSchema;
 49    }
 50
 51    public void initialize(String name, final Scheduler scheduler)
 52        throws SchedulerException {
 53
 54        this.pluginName = name;
 55        this.scheduler = scheduler;
 56
 57        logger.debug("Registering Plugin " + pluginName);
 58        // Load the job definitions from the specified directory
 59        loadJobs();
 60    }
 61
 62    private void loadJobs() throws SchedulerException {
 63
 64        File dir = null;
 65
 66        // Check directory
 67        if (getJobsDirectory() == null
 68            || !(dir =
 69            new File(getJobsDirectory())).exists()) {
 70            throw new SchedulerConfigException(
 71                "The jobs directory was missing "
 72                    + jobsDirectory);
 73
 74        }
 75        logger.info("Loading jobs from " + dir.getName());
 76
 77        // Only XML files, filtering out any directories
 78        this.jobFiles = dir.listFiles(new XMLFileOnlyFilter());
 79    }
 80
 81    public void start() {
 82        processJobs();
 83    }
 84
 85    public void shutdown() {
 86        // nothing to clean up
 87    }
 88
 89    public void processJobs() {
 90        // There should be at least one job
 91        if (getJobFiles() == null || getJobFiles().length == 0) {
 92            return;
 93        }
 94
 95        JobSchedulingDataProcessor processor =
 96            new JobSchedulingDataProcessor(
 97                true, isValidateXML(), isValidateSchema());
 98
 99        int size = getJobFiles().length;
100        for (int i = 0; i < size; i++) {
101            File jobFile = getJobFiles()[i];
102
103            String fileName = jobFile.getAbsolutePath();
104            logger.debug("Loading job file: " + fileName);
105
106            try {
107
108                processor.processFileAndScheduleJobs(
109                    fileName, scheduler, true);
110
111            } catch (Exception ex) {
112                logger.error("Error loading jobs: " + fileName);
113                logger.error(ex);
114            }
115        }
116    }
117
118    public String getJobsDirectory() {
119        return jobsDirectory;
120    }
121
122    public void setJobsDirectory(String jobsDirectory) {
123        this.jobsDirectory = jobsDirectory;
124    }
125
126    public String getPluginName() {
127        return pluginName;
128    }
129
130    public void setPluginName(String pluginName) {
131        this.pluginName = pluginName;
132    }
133
134    public boolean isValidateXML() {
135        return validateXML;
136    }
137
138    public void setValidateXML(boolean validateXML) {
139        this.validateXML = validateXML;
140    }
141}