下面列出了怎么用org.quartz.impl.matchers.EverythingMatcher的API类实例代码及写法,或者点击链接到github查看源代码。
public void addJobListener(JobListener jobListener, List<Matcher<JobKey>> matchers) {
if (jobListener.getName() == null || jobListener.getName().length() == 0) {
throw new IllegalArgumentException(
"JobListener name cannot be empty.");
}
synchronized (globalJobListeners) {
globalJobListeners.put(jobListener.getName(), jobListener);
LinkedList<Matcher<JobKey>> matchersL = new LinkedList<Matcher<JobKey>>();
if(matchers != null && matchers.size() > 0)
matchersL.addAll(matchers);
else
matchersL.add(EverythingMatcher.allJobs());
globalJobListenersMatchers.put(jobListener.getName(), matchersL);
}
}
public void addJobListener(JobListener jobListener, Matcher<JobKey> matcher) {
if (jobListener.getName() == null || jobListener.getName().length() == 0) {
throw new IllegalArgumentException(
"JobListener name cannot be empty.");
}
synchronized (globalJobListeners) {
globalJobListeners.put(jobListener.getName(), jobListener);
LinkedList<Matcher<JobKey>> matchersL = new LinkedList<Matcher<JobKey>>();
if(matcher != null)
matchersL.add(matcher);
else
matchersL.add(EverythingMatcher.allJobs());
globalJobListenersMatchers.put(jobListener.getName(), matchersL);
}
}
public void addTriggerListener(TriggerListener triggerListener, List<Matcher<TriggerKey>> matchers) {
if (triggerListener.getName() == null
|| triggerListener.getName().length() == 0) {
throw new IllegalArgumentException(
"TriggerListener name cannot be empty.");
}
synchronized (globalTriggerListeners) {
globalTriggerListeners.put(triggerListener.getName(), triggerListener);
LinkedList<Matcher<TriggerKey>> matchersL = new LinkedList<Matcher<TriggerKey>>();
if(matchers != null && matchers.size() > 0)
matchersL.addAll(matchers);
else
matchersL.add(EverythingMatcher.allTriggers());
globalTriggerListenersMatchers.put(triggerListener.getName(), matchersL);
}
}
@Override
public void addGlobalJobListener(JobListener jobGlobalListener) throws SchedulerException {
final Scheduler defaultScheduler;
final List<Matcher<JobKey>> allJobs = new ArrayList<Matcher<JobKey>>();
allJobs.add(EverythingMatcher.allJobs());
if (Parameter.QUARTZ_DEFAULT_LISTENER_DISABLED.getValueAsBoolean()) {
defaultScheduler = null;
LOG.debug("Initialization of Quartz default listener has been disabled");
} else {
defaultScheduler = StdSchedulerFactory.getDefaultScheduler();
defaultScheduler.getListenerManager().addJobListener(jobGlobalListener, allJobs);
}
for (final Scheduler scheduler : JobInformations.getAllSchedulers()) {
if (scheduler != defaultScheduler) {
scheduler.getListenerManager().addJobListener(jobGlobalListener, allJobs);
}
}
}
private Context() throws Exception {
this.token = UUID.randomUUID().toString();
this.applications = new Applications();
this.queues = new ArrayList<AbstractQueue<?>>();
this.scheduler = new StdSchedulerFactory(SchedulerFactoryProperties.concrete()).getScheduler();
this.scheduler.getListenerManager().addJobListener(new JobReportListener(), EverythingMatcher.allJobs());
this.scheduler.start();
}
private Context() throws Exception {
SslTools.ignoreSsl();
this.applications = new Applications();
this.token = UUID.randomUUID().toString();
this.queues = new ArrayList<AbstractQueue<?>>();
this.scheduler = new StdSchedulerFactory(SchedulerFactoryProperties.concrete()).getScheduler();
this.scheduler.getListenerManager().addJobListener(new JobReportListener(), EverythingMatcher.allJobs());
this.scheduler.start();
}
public void addJobListener(JobListener jobListener) {
addJobListener(jobListener, EverythingMatcher.allJobs());
}
public void addTriggerListener(TriggerListener triggerListener) {
addTriggerListener(triggerListener, EverythingMatcher.allTriggers());
}
/**
* <p>
* Called during creation of the <code>Scheduler</code> in order to give
* the <code>SchedulerPlugin</code> a chance to initialize.
* </p>
*
* @throws SchedulerConfigException
* if there is an error initializing.
*/
public void initialize(String pname, Scheduler scheduler, ClassLoadHelper classLoadHelper)
throws SchedulerException {
this.name = pname;
scheduler.getListenerManager().addTriggerListener(this, EverythingMatcher.allTriggers());
}
/**
* <p>
* Called during creation of the <code>Scheduler</code> in order to give
* the <code>SchedulerPlugin</code> a chance to initialize.
* </p>
*
* @throws SchedulerConfigException
* if there is an error initializing.
*/
public void initialize(String pname, Scheduler scheduler,ClassLoadHelper classLoadHelper)
throws SchedulerException {
this.name = pname;
scheduler.getListenerManager().addJobListener(this, EverythingMatcher.allJobs());
}