intervallistenerdemo.java

Quartz1.6的例子

/* =================================
 * 文  件： IntervalListenerDemo.java
 * 公  司： 南京中兴软件有限责任公司     
 * 版  权： Copyright (c) 2008      
 * 日  期： Mar 30, 2008                
 * ================================= */

package org.quartz.examples.example15;

import java.util.Calendar;
import java.util.Date;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.quartz.JobDetail;
import org.quartz.JobListener;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.SchedulerMetaData;
import org.quartz.SimpleTrigger;
import org.quartz.impl.StdSchedulerFactory;

/**
 * <p />描    述：TODO 请在这里写下描述
 * <p />@version 1.0.0
 * <p />@author  zhangzb158115
 * <p />
 * <p />========= 修改记录[BEGIN] =========
 * <p />修改日期：
 * <p />修 改 人：
 * <p />修改版本：
 * <p />修改原因：
 * <p />修改内容：
 * <p />========= 修改记录[ END ] =========
 * <p />
 */
public class IntervalListenerDemo {
    public void run() throws Exception {
        Log log = LogFactory.getLog(IntervalListenerDemo.class);

        // First we must get a reference to a scheduler
        SchedulerFactory sf = new StdSchedulerFactory();
        Scheduler sched = sf.getScheduler();

        //Calculate the start time of all triggers as 5 seconds from now
        Calendar startTime = Calendar.getInstance();
        startTime.add(Calendar.SECOND, 2);

        // schedule a job to run immediately
        JobDetail job = new JobDetail("job1", "group1", SimpleJob.class);
        SimpleTrigger trigger = new SimpleTrigger("trigger1", "group1", startTime.getTime(), null,
                                                  SimpleTrigger.REPEAT_INDEFINITELY, 3L);
        // Set up the listener
        JobListener listener = new IntervalListener();
        sched.addJobListener(listener);

        // make sure the listener is associated with the job
        job.addJobListener(listener.getName());

        // schedule the job to run
        sched.scheduleJob(job, trigger);

        // All of the jobs have been added to the scheduler, but none of the jobs
        // will run until the scheduler has been started
        log.info("------- Starting Scheduler ----------------");
        sched.start();

        // wait 30 seconds:
        // note:  nothing will run
        log.info("------- Waiting 35 seconds... --------------");
        try {
            // wait 30 seconds to show jobs
            Thread.sleep(35L * 1000L);
            // executing...
        } catch (Exception e) {
        }

        // shut down the scheduler
        log.info("------- Shutting Down ---------------------");
        sched.shutdown(true);
        log.info("------- Shutdown Complete -----------------");

        SchedulerMetaData metaData = sched.getMetaData();
        log.info("Executed " + metaData.numJobsExecuted() + " jobs.");

    }

    public static void main(String[] args) throws Exception {
        IntervalListenerDemo demo = new IntervalListenerDemo();
        demo.run();

    }
}