下面列出了怎么用org.quartz.SchedulerListener的API类实例代码及写法,或者点击链接到github查看源代码。
public void notifySchedulerListenersJobDeleted(String jobName, String groupName) {
// build a list of all job listeners that are to be notified...
List schedListeners = getSchedulerListeners();
// notify all scheduler listeners
java.util.Iterator itr = schedListeners.iterator();
while (itr.hasNext()) {
SchedulerListener sl = (SchedulerListener) itr.next();
try {
sl.jobDeleted(jobName, groupName);
} catch (Exception e) {
getLog().error(
"Error while notifying SchedulerListener of JobAdded.",
e);
}
}
}
public void notifySchedulerListenersPausedJob(String name, String group) {
// build a list of all job listeners that are to be notified...
List schedListeners = getSchedulerListeners();
// notify all scheduler listeners
java.util.Iterator itr = schedListeners.iterator();
while (itr.hasNext()) {
SchedulerListener sl = (SchedulerListener) itr.next();
try {
sl.jobsPaused(name, group);
} catch (Exception e) {
getLog().error(
"Error while notifying SchedulerListener of paused job/group."
+ " Job=" + group + "." + name, e);
}
}
}
public void notifySchedulerListenersFinalized(Trigger trigger) {
// build a list of all scheduler listeners that are to be notified...
List schedListeners = getSchedulerListeners();
// notify all scheduler listeners
java.util.Iterator itr = schedListeners.iterator();
while (itr.hasNext()) {
SchedulerListener sl = (SchedulerListener) itr.next();
try {
sl.triggerFinalized(trigger);
} catch (Exception e) {
getLog().error(
"Error while notifying SchedulerListener of finalized trigger."
+ " Triger=" + trigger.getFullName(), e);
}
}
}
public void notifySchedulerListenersResumedJob(String name, String group) {
// build a list of all job listeners that are to be notified...
List schedListeners = getSchedulerListeners();
// notify all scheduler listeners
java.util.Iterator itr = schedListeners.iterator();
while (itr.hasNext()) {
SchedulerListener sl = (SchedulerListener) itr.next();
try {
sl.jobsResumed(name, group);
} catch (Exception e) {
getLog().error(
"Error while notifying SchedulerListener of resumed job/group."
+ " Job=" + group + "." + name, e);
}
}
}
public void notifySchedulerListenersResumedTrigger(String name, String group) {
// build a list of all job listeners that are to be notified...
List schedListeners = getSchedulerListeners();
// notify all scheduler listeners
java.util.Iterator itr = schedListeners.iterator();
while (itr.hasNext()) {
SchedulerListener sl = (SchedulerListener) itr.next();
try {
sl.triggersResumed(name, group);
} catch (Exception e) {
getLog().error(
"Error while notifying SchedulerListener of resumed trigger/group."
+ " Triger=" + group + "." + name, e);
}
}
}
public void notifySchedulerListenersError(String msg, SchedulerException se) {
// build a list of all scheduler listeners that are to be notified...
List<SchedulerListener> schedListeners = buildSchedulerListenerList();
// notify all scheduler listeners
for(SchedulerListener sl: schedListeners) {
try {
sl.schedulerError(msg, se);
} catch (Exception e) {
getLog()
.error(
"Error while notifying SchedulerListener of error: ",
e);
getLog().error(
" Original error (for notification) was: " + msg, se);
}
}
}
public void notifySchedulerListenersInStandbyMode() {
// build a list of all job listeners that are to be notified...
List schedListeners = getSchedulerListeners();
// notify all scheduler listeners
java.util.Iterator itr = schedListeners.iterator();
while (itr.hasNext()) {
SchedulerListener sl = (SchedulerListener) itr.next();
try {
sl.schedulerInStandbyMode();
} catch (Exception e) {
getLog().error(
"Error while notifying SchedulerListener of inStandByMode.",
e);
}
}
}
public void notifySchedulerListenersUnscheduled(TriggerKey triggerKey) {
// build a list of all scheduler listeners that are to be notified...
List<SchedulerListener> schedListeners = buildSchedulerListenerList();
// notify all scheduler listeners
for(SchedulerListener sl: schedListeners) {
try {
if(triggerKey == null)
sl.schedulingDataCleared();
else
sl.jobUnscheduled(triggerKey);
} catch (Exception e) {
getLog().error(
"Error while notifying SchedulerListener of unscheduled job."
+ " Triger=" + (triggerKey == null ? "ALL DATA" : triggerKey), e);
}
}
}
public void notifySchedulerListenersShutdown() {
// build a list of all job listeners that are to be notified...
List schedListeners = getSchedulerListeners();
// notify all scheduler listeners
java.util.Iterator itr = schedListeners.iterator();
while (itr.hasNext()) {
SchedulerListener sl = (SchedulerListener) itr.next();
try {
sl.schedulerShutdown();
} catch (Exception e) {
getLog().error(
"Error while notifying SchedulerListener of shutdown.",
e);
}
}
}
public void notifySchedulerListenersUnscheduled(String triggerName,
String triggerGroup) {
// build a list of all scheduler listeners that are to be notified...
List schedListeners = getSchedulerListeners();
// notify all scheduler listeners
java.util.Iterator itr = schedListeners.iterator();
while (itr.hasNext()) {
SchedulerListener sl = (SchedulerListener) itr.next();
try {
sl.jobUnscheduled(triggerName, triggerGroup);
} catch (Exception e) {
getLog().error(
"Error while notifying SchedulerListener of unscheduled job."
+ " Triger=" + triggerGroup + "."
+ triggerName, e);
}
}
}
public void notifySchedulerListenersJobAdded(JobDetail jobDetail) {
// build a list of all job listeners that are to be notified...
List schedListeners = getSchedulerListeners();
// notify all scheduler listeners
java.util.Iterator itr = schedListeners.iterator();
while (itr.hasNext()) {
SchedulerListener sl = (SchedulerListener) itr.next();
try {
sl.jobAdded(jobDetail);
} catch (Exception e) {
getLog().error(
"Error while notifying SchedulerListener of JobAdded.",
e);
}
}
}
public void notifySchedulerListenersStarted() {
// build a list of all job listeners that are to be notified...
List schedListeners = getSchedulerListeners();
// notify all scheduler listeners
java.util.Iterator itr = schedListeners.iterator();
while (itr.hasNext()) {
SchedulerListener sl = (SchedulerListener) itr.next();
try {
sl.schedulerStarted();
} catch (Exception e) {
getLog().error(
"Error while notifying SchedulerListener of startup.",
e);
}
}
}
public void notifySchedulerListenersSchduled(Trigger trigger) {
// build a list of all scheduler listeners that are to be notified...
List schedListeners = getSchedulerListeners();
// notify all scheduler listeners
java.util.Iterator itr = schedListeners.iterator();
while (itr.hasNext()) {
SchedulerListener sl = (SchedulerListener) itr.next();
try {
sl.jobScheduled(trigger);
} catch (Exception e) {
getLog().error(
"Error while notifying SchedulerListener of scheduled job."
+ " Triger=" + trigger.getFullName(), e);
}
}
}
public void jobAdded(JobDetail jobDetail) {
Iterator<SchedulerListener> itr = listeners.iterator();
while(itr.hasNext()) {
SchedulerListener l = itr.next();
l.jobAdded(jobDetail);
}
}
public void jobDeleted(JobKey jobKey) {
Iterator<SchedulerListener> itr = listeners.iterator();
while(itr.hasNext()) {
SchedulerListener l = itr.next();
l.jobDeleted(jobKey);
}
}
public void jobScheduled(Trigger trigger) {
Iterator<SchedulerListener> itr = listeners.iterator();
while(itr.hasNext()) {
SchedulerListener l = itr.next();
l.jobScheduled(trigger);
}
}
public void triggerFinalized(Trigger trigger) {
Iterator<SchedulerListener> itr = listeners.iterator();
while(itr.hasNext()) {
SchedulerListener l = itr.next();
l.triggerFinalized(trigger);
}
}
public void triggerPaused(TriggerKey key) {
Iterator<SchedulerListener> itr = listeners.iterator();
while(itr.hasNext()) {
SchedulerListener l = itr.next();
l.triggerPaused(key);
}
}
public void triggersPaused(String triggerGroup) {
Iterator<SchedulerListener> itr = listeners.iterator();
while(itr.hasNext()) {
SchedulerListener l = itr.next();
l.triggersPaused(triggerGroup);
}
}
public void triggerResumed(TriggerKey key) {
Iterator<SchedulerListener> itr = listeners.iterator();
while(itr.hasNext()) {
SchedulerListener l = itr.next();
l.triggerResumed(key);
}
}
public void triggersResumed(String triggerGroup) {
Iterator<SchedulerListener> itr = listeners.iterator();
while(itr.hasNext()) {
SchedulerListener l = itr.next();
l.triggersResumed(triggerGroup);
}
}
public void schedulingDataCleared() {
Iterator<SchedulerListener> itr = listeners.iterator();
while(itr.hasNext()) {
SchedulerListener l = itr.next();
l.schedulingDataCleared();
}
}
public void jobPaused(JobKey key) {
Iterator<SchedulerListener> itr = listeners.iterator();
while(itr.hasNext()) {
SchedulerListener l = itr.next();
l.jobPaused(key);
}
}
public void jobsPaused(String jobGroup) {
Iterator<SchedulerListener> itr = listeners.iterator();
while(itr.hasNext()) {
SchedulerListener l = itr.next();
l.jobsPaused(jobGroup);
}
}
public void jobsResumed(String jobGroup) {
Iterator<SchedulerListener> itr = listeners.iterator();
while(itr.hasNext()) {
SchedulerListener l = itr.next();
l.jobsResumed(jobGroup);
}
}
public void schedulerStarted() {
Iterator<SchedulerListener> itr = listeners.iterator();
while(itr.hasNext()) {
SchedulerListener l = itr.next();
l.schedulerStarted();
}
}
public void schedulerShutdown() {
Iterator<SchedulerListener> itr = listeners.iterator();
while(itr.hasNext()) {
SchedulerListener l = itr.next();
l.schedulerShutdown();
}
}
public void schedulerShuttingdown() {
Iterator<SchedulerListener> itr = listeners.iterator();
while(itr.hasNext()) {
SchedulerListener l = itr.next();
l.schedulerShuttingdown();
}
}
private List<SchedulerListener> buildSchedulerListenerList() {
List<SchedulerListener> allListeners = new LinkedList<SchedulerListener>();
allListeners.addAll(getListenerManager().getSchedulerListeners());
allListeners.addAll(getInternalSchedulerListeners());
return allListeners;
}
public void notifySchedulerListenersFinalized(Trigger trigger) {
// build a list of all scheduler listeners that are to be notified...
List<SchedulerListener> schedListeners = buildSchedulerListenerList();
// notify all scheduler listeners
for(SchedulerListener sl: schedListeners) {
try {
sl.triggerFinalized(trigger);
} catch (Exception e) {
getLog().error(
"Error while notifying SchedulerListener of finalized trigger."
+ " Triger=" + trigger.getKey(), e);
}
}
}