Java 类org.quartz.spi.SchedulerPlugin 实例源码

private void shutdownPlugins() {
    java.util.Iterator<SchedulerPlugin> itr = resources.getSchedulerPlugins().iterator();
    while (itr.hasNext()) {
        SchedulerPlugin plugin = itr.next();
        plugin.shutdown();
    }
}

private void startPlugins() {
    java.util.Iterator<SchedulerPlugin> itr = resources.getSchedulerPlugins().iterator();
    while (itr.hasNext()) {
        SchedulerPlugin plugin = itr.next();
        plugin.start();
    }
}

private void shutdownPlugins() {
    java.util.Iterator itr = resources.getSchedulerPlugins().iterator();
    while (itr.hasNext()) {
        SchedulerPlugin plugin = (SchedulerPlugin) itr.next();
        plugin.shutdown();
    }
}

private void startPlugins() {
    java.util.Iterator itr = resources.getSchedulerPlugins().iterator();
    while (itr.hasNext()) {
        SchedulerPlugin plugin = (SchedulerPlugin) itr.next();
        plugin.start();
    }
}

/**
 * Creates a scheduler using the specified thread pool, job store, and
 * plugins, and binds it to RMI.
 *
 * @param schedulerName
 *          The name for the scheduler.
 * @param schedulerInstanceId
 *          The instance ID for the scheduler.
 * @param threadPool
 *          The thread pool for executing jobs
 * @param jobStore
 *          The type of job store
 * @param schedulerPluginMap
 *          Map from a <code>String</code> plugin names to
 *          <code>{@link org.quartz.spi.SchedulerPlugin}</code>s.  Can use
 *          "null" if no plugins are required.
 * @param rmiRegistryHost
 *          The hostname to register this scheduler with for RMI. Can use
 *          "null" if no RMI is required.
 * @param rmiRegistryPort
 *          The port for RMI. Typically 1099.
 * @param idleWaitTime
 *          The idle wait time in milliseconds. You can specify "-1" for
 *          the default value, which is currently 30000 ms.
 * @throws SchedulerException
 *           if initialization failed
 */
public void createScheduler(String schedulerName,
        String schedulerInstanceId, ThreadPool threadPool,
        JobStore jobStore, Map<String, SchedulerPlugin> schedulerPluginMap,
        String rmiRegistryHost, int rmiRegistryPort,
        long idleWaitTime, long dbFailureRetryInterval,
        boolean jmxExport, String jmxObjectName)
    throws SchedulerException {
    createScheduler(schedulerName, schedulerInstanceId, threadPool,
            DEFAULT_THREAD_EXECUTOR, jobStore, schedulerPluginMap,
            rmiRegistryHost, rmiRegistryPort, idleWaitTime,
            dbFailureRetryInterval, jmxExport, jmxObjectName);
}

/**
 * Creates a scheduler using the specified thread pool, job store, and
 * plugins, and binds it to RMI.
 *
 * @param schedulerName
 *          The name for the scheduler.
 * @param schedulerInstanceId
 *          The instance ID for the scheduler.
 * @param threadPool
 *          The thread pool for executing jobs
 * @param threadExecutor
 *          The thread executor for executing jobs
 * @param jobStore
 *          The type of job store
 * @param schedulerPluginMap
 *          Map from a <code>String</code> plugin names to
 *          <code>{@link org.quartz.spi.SchedulerPlugin}</code>s.  Can use
 *          "null" if no plugins are required.
 * @param rmiRegistryHost
 *          The hostname to register this scheduler with for RMI. Can use
 *          "null" if no RMI is required.
 * @param rmiRegistryPort
 *          The port for RMI. Typically 1099.
 * @param idleWaitTime
 *          The idle wait time in milliseconds. You can specify "-1" for
 *          the default value, which is currently 30000 ms.
 * @throws SchedulerException
 *           if initialization failed
 */
public void createScheduler(String schedulerName,
        String schedulerInstanceId, ThreadPool threadPool,
        ThreadExecutor threadExecutor,
        JobStore jobStore, Map<String, SchedulerPlugin> schedulerPluginMap,
        String rmiRegistryHost, int rmiRegistryPort,
        long idleWaitTime, long dbFailureRetryInterval,
        boolean jmxExport, String jmxObjectName)
    throws SchedulerException {
    createScheduler(schedulerName, schedulerInstanceId, threadPool,
            DEFAULT_THREAD_EXECUTOR, jobStore, schedulerPluginMap,
            rmiRegistryHost, rmiRegistryPort, idleWaitTime,
            dbFailureRetryInterval, jmxExport, jmxObjectName, DEFAULT_BATCH_MAX_SIZE, DEFAULT_BATCH_TIME_WINDOW);
}

/**
 * <p>
 * Add the given <code>{@link org.quartz.spi.SchedulerPlugin}</code> for the 
 * <code>{@link QuartzScheduler}</code> to use. This method expects the plugin's
 * "initialize" method to be invoked externally (either before or after
 * this method is called).
 * </p>
 */
public void addSchedulerPlugin(SchedulerPlugin plugin) {
    schedulerPlugins.add(plugin);
}

/**
 * <p>
 * Get the <code>List</code> of all 
 * <code>{@link org.quartz.spi.SchedulerPlugin}</code>s for the 
 * <code>{@link QuartzScheduler}</code> to use.
 * </p>
 */
public List<SchedulerPlugin> getSchedulerPlugins() {
    return schedulerPlugins;
}

/**
 * <p>
 * Add the given <code>{@link org.quartz.spi.SchedulerPlugin}</code> for the 
 * <code>{@link QuartzScheduler}</code> to use. This method expects the plugin's
 * "initialize" method to be invoked externally (either before or after
 * this method is called).
 * </p>
 */
public void addSchedulerPlugin(SchedulerPlugin plugin) {
    schedulerPlugins.add(plugin);
}