package com;
import org.quartz.SchedulerException;
import org.quartz.SchedulerListener;
import org.quartz.Trigger;
/** *//**
* 實(shí)現(xiàn)自己的Scheduler監(jiān)聽器
*
* @author zdw
*
*/
public class MySchedulerListener implements SchedulerListener
{
/** *//**
* 當(dāng)一個(gè)JobDetail被scheduler的時(shí)候執(zhí)行
*/
public void jobScheduled(Trigger trigger)
{
System.out.println("jobSchedulerd fire:" + trigger.getName());
}
/** *//**
* 當(dāng)一個(gè)JobDetail被排除在scheduler之外的時(shí)候執(zhí)行
*/
public void jobUnscheduled(String triggerName, String triggerGroup)
{
System.out.println("jobUnschedulerd fire:" + triggerName + " ,"
+ triggerGroup);
}
/** *//**
* 當(dāng)Trigger被暫停的時(shí)候執(zhí)行
*/
public void jobsPaused(String triggerName, String triggerGroup)
{
System.out.println("jobPaused fire:" + triggerName + " ,"
+ triggerGroup);
}
/** *//**
* 當(dāng)Trigger被解除暫停的時(shí)候執(zhí)行
*/
public void jobsResumed(String triggerName, String triggerGroup)
{
System.out.println("jobResumed fire:" + triggerName + " ,"
+ triggerGroup);
}
/** *//**
* 當(dāng)scheduler發(fā)生嚴(yán)重錯(cuò)誤的時(shí)候執(zhí)行
*/
public void schedulerError(String msg, SchedulerException cause)
{
System.out.println("scheduler錯(cuò)誤,具體消息為:" + msg);
System.out.println(cause.getMessage());
}
/** *//**
* 當(dāng)scheduler被關(guān)閉的時(shí)候執(zhí)行
*/
public void schedulerShutdown()
{
System.out.println("scheduler shutdown");
}
/** *//**
* 調(diào)用scheduler，當(dāng)trigger到達(dá)一定條件的時(shí)候,scheduler就永遠(yuǎn)不會(huì)再fire
*/
public void triggerFinalized(Trigger arg0)
{
System.out.println("trigger finalized");
}
/** *//**
* 當(dāng)trigger或trigger所在的組被暫停的時(shí)候執(zhí)行
*/
public void triggersPaused(String triggerName, String triggerGroup)
{
System.out.println("trigger paused");
}
/** *//**
* 當(dāng)trigger被解除暫停的時(shí)候被執(zhí)行
*/
public void triggersResumed(String triggerName, String triggerGroup)
{
System.out.println("trigger resume");
}
}
調(diào)用部分:
sched.addSchedulerListener(new MySchedulerListener());
一個(gè)簡(jiǎn)單的SchedulerListener就寫完了,在這里你可以完成自己的邏輯與控制.