类org.quartz.SchedulerListener源码实例Demo

下面列出了怎么用org.quartz.SchedulerListener的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: AsuraFramework   文件: QuartzScheduler.java
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);
        }
    }
}
 
源代码2 项目: AsuraFramework   文件: QuartzScheduler.java
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);
        }
    }
}
 
源代码3 项目: AsuraFramework   文件: QuartzScheduler.java
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);
        }
    }
}
 
源代码4 项目: AsuraFramework   文件: QuartzScheduler.java
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);
        }
    }
}
 
源代码5 项目: AsuraFramework   文件: QuartzScheduler.java
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);
        }
    }
}
 
源代码6 项目: lams   文件: QuartzScheduler.java
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);
        }
    }
}
 
源代码7 项目: AsuraFramework   文件: QuartzScheduler.java
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);
        }
    }
}
 
源代码8 项目: lams   文件: QuartzScheduler.java
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);
        }
    }
}
 
源代码9 项目: AsuraFramework   文件: QuartzScheduler.java
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);
        }
    }
}
 
源代码10 项目: AsuraFramework   文件: QuartzScheduler.java
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);
        }
    }
}
 
源代码11 项目: AsuraFramework   文件: QuartzScheduler.java
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);
        }
    }
}
 
源代码12 项目: AsuraFramework   文件: QuartzScheduler.java
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);
        }
    }
}
 
源代码13 项目: AsuraFramework   文件: QuartzScheduler.java
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);
        }
    }
}
 
源代码14 项目: lams   文件: BroadcastSchedulerListener.java
public void jobAdded(JobDetail jobDetail) {
    Iterator<SchedulerListener> itr = listeners.iterator();
    while(itr.hasNext()) {
        SchedulerListener l = itr.next();
        l.jobAdded(jobDetail);
    }
}
 
源代码15 项目: lams   文件: BroadcastSchedulerListener.java
public void jobDeleted(JobKey jobKey) {
    Iterator<SchedulerListener> itr = listeners.iterator();
    while(itr.hasNext()) {
        SchedulerListener l = itr.next();
        l.jobDeleted(jobKey);
    }
}
 
源代码16 项目: lams   文件: BroadcastSchedulerListener.java
public void jobScheduled(Trigger trigger) {
    Iterator<SchedulerListener> itr = listeners.iterator();
    while(itr.hasNext()) {
        SchedulerListener l = itr.next();
        l.jobScheduled(trigger);
    }
}
 
源代码17 项目: lams   文件: BroadcastSchedulerListener.java
public void triggerFinalized(Trigger trigger) {
    Iterator<SchedulerListener> itr = listeners.iterator();
    while(itr.hasNext()) {
        SchedulerListener l = itr.next();
        l.triggerFinalized(trigger);
    }
}
 
源代码18 项目: lams   文件: BroadcastSchedulerListener.java
public void triggerPaused(TriggerKey key) {
    Iterator<SchedulerListener> itr = listeners.iterator();
    while(itr.hasNext()) {
        SchedulerListener l = itr.next();
        l.triggerPaused(key);
    }
}
 
源代码19 项目: lams   文件: BroadcastSchedulerListener.java
public void triggersPaused(String triggerGroup) {
    Iterator<SchedulerListener> itr = listeners.iterator();
    while(itr.hasNext()) {
        SchedulerListener l = itr.next();
        l.triggersPaused(triggerGroup);
    }
}
 
源代码20 项目: lams   文件: BroadcastSchedulerListener.java
public void triggerResumed(TriggerKey key) {
    Iterator<SchedulerListener> itr = listeners.iterator();
    while(itr.hasNext()) {
        SchedulerListener l = itr.next();
        l.triggerResumed(key);
    }
}
 
源代码21 项目: lams   文件: BroadcastSchedulerListener.java
public void triggersResumed(String triggerGroup) {
    Iterator<SchedulerListener> itr = listeners.iterator();
    while(itr.hasNext()) {
        SchedulerListener l = itr.next();
        l.triggersResumed(triggerGroup);
    }
}
 
源代码22 项目: lams   文件: BroadcastSchedulerListener.java
public void schedulingDataCleared() {
    Iterator<SchedulerListener> itr = listeners.iterator();
    while(itr.hasNext()) {
        SchedulerListener l = itr.next();
        l.schedulingDataCleared();
    }
}
 
源代码23 项目: lams   文件: BroadcastSchedulerListener.java
public void jobPaused(JobKey key) {
    Iterator<SchedulerListener> itr = listeners.iterator();
    while(itr.hasNext()) {
        SchedulerListener l = itr.next();
        l.jobPaused(key);
    }
}
 
源代码24 项目: lams   文件: BroadcastSchedulerListener.java
public void jobsPaused(String jobGroup) {
    Iterator<SchedulerListener> itr = listeners.iterator();
    while(itr.hasNext()) {
        SchedulerListener l = itr.next();
        l.jobsPaused(jobGroup);
    }
}
 
源代码25 项目: lams   文件: BroadcastSchedulerListener.java
public void jobsResumed(String jobGroup) {
    Iterator<SchedulerListener> itr = listeners.iterator();
    while(itr.hasNext()) {
        SchedulerListener l = itr.next();
        l.jobsResumed(jobGroup);
    }
}
 
源代码26 项目: lams   文件: BroadcastSchedulerListener.java
public void schedulerStarted() {
    Iterator<SchedulerListener> itr = listeners.iterator();
    while(itr.hasNext()) {
        SchedulerListener l = itr.next();
        l.schedulerStarted();
    }
}
 
源代码27 项目: lams   文件: BroadcastSchedulerListener.java
public void schedulerShutdown() {
    Iterator<SchedulerListener> itr = listeners.iterator();
    while(itr.hasNext()) {
        SchedulerListener l = itr.next();
        l.schedulerShutdown();
    }
}
 
源代码28 项目: lams   文件: BroadcastSchedulerListener.java
public void schedulerShuttingdown() {
    Iterator<SchedulerListener> itr = listeners.iterator();
    while(itr.hasNext()) {
        SchedulerListener l = itr.next();
        l.schedulerShuttingdown();
    }
}
 
源代码29 项目: lams   文件: QuartzScheduler.java
private List<SchedulerListener> buildSchedulerListenerList() {
    List<SchedulerListener> allListeners = new LinkedList<SchedulerListener>();
    allListeners.addAll(getListenerManager().getSchedulerListeners());
    allListeners.addAll(getInternalSchedulerListeners());

    return allListeners;
}
 
源代码30 项目: lams   文件: QuartzScheduler.java
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);
        }
    }
}
 
 类所在包
 同包方法