public class QuartzScheduler extends Object implements RemotableQuartzScheduler
This is the heart of Quartz, an indirect implementation of the
interface, containing methods to schedule Scheduler
s,
register Job
instances, etc.
JobListener
Scheduler
,
QuartzSchedulerThread
,
JobStore
,
ThreadPool
Constructor and Description |
---|
QuartzScheduler(QuartzSchedulerResources resources,
long idleWaitTime,
long dbRetryInterval)
Create a
QuartzScheduler with the given configuration
properties. |
Modifier and Type | Method and Description |
---|---|
void |
addCalendar(String calName,
Calendar calendar,
boolean replace,
boolean updateTriggers)
Add (register) the given
Calendar to the Scheduler. |
void |
addInternalJobListener(JobListener jobListener)
Add the given
to the
Scheduler 's internal list. |
void |
addInternalSchedulerListener(SchedulerListener schedulerListener)
Register the given
with the
Scheduler 's list of internal listeners. |
void |
addInternalTriggerListener(TriggerListener triggerListener)
Add the given
to the
Scheduler 's internal list. |
void |
addJob(JobDetail jobDetail,
boolean replace)
Add the given
Job to the Scheduler - with no associated
Trigger . |
void |
addJob(JobDetail jobDetail,
boolean replace,
boolean storeNonDurableWhileAwaitingScheduling) |
void |
addNoGCObject(Object obj) |
boolean |
checkExists(JobKey jobKey)
Determine whether a
Job with the given identifier already
exists within the scheduler. |
boolean |
checkExists(TriggerKey triggerKey)
Determine whether a
Trigger with the given identifier already
exists within the scheduler. |
void |
clear()
|
boolean |
deleteCalendar(String calName)
Delete the identified
Calendar from the Scheduler. |
boolean |
deleteJob(JobKey jobKey)
Delete the identified
Job from the Scheduler - and any
associated Trigger s. |
boolean |
deleteJobs(List<JobKey> jobKeys) |
Calendar |
getCalendar(String calName)
Get the
instance with the given name. |
List<String> |
getCalendarNames()
Get the names of all registered
. |
List<JobExecutionContext> |
getCurrentlyExecutingJobs()
Return a list of
JobExecutionContext objects that
represent all currently executing Jobs in this Scheduler instance. |
JobListener |
getInternalJobListener(String name)
Get the internal
that has the given name. |
List<JobListener> |
getInternalJobListeners()
Get a List containing all of the
s
in the Scheduler 's internal list. |
List<SchedulerListener> |
getInternalSchedulerListeners()
Get a List containing all of the internal
s
registered with the Scheduler . |
TriggerListener |
getInternalTriggerListener(String name)
Get the internal
that
has the given name. |
List<TriggerListener> |
getInternalTriggerListeners()
Get a list containing all of the
s
in the Scheduler 's internal list. |
JobDetail |
getJobDetail(JobKey jobKey)
Get the
for the Job
instance with the given name and group. |
JobFactory |
getJobFactory() |
List<String> |
getJobGroupNames()
Get the names of all known
groups. |
Set<JobKey> |
getJobKeys(GroupMatcher<JobKey> matcher)
Get the names of all the
in the
matching groups. |
Class<?> |
getJobStoreClass() |
ListenerManager |
getListenerManager() |
org.slf4j.Logger |
getLog() |
Set<String> |
getPausedTriggerGroups() |
SchedulerContext |
getSchedulerContext()
Returns the
SchedulerContext of the Scheduler . |
String |
getSchedulerInstanceId()
Returns the instance Id of the
QuartzScheduler . |
String |
getSchedulerName()
Returns the name of the
QuartzScheduler . |
SchedulerSignaler |
getSchedulerSignaler() |
ThreadGroup |
getSchedulerThreadGroup()
Returns the name of the thread group for Quartz's main threads.
|
Class<?> |
getThreadPoolClass() |
int |
getThreadPoolSize() |
Trigger |
getTrigger(TriggerKey triggerKey)
Get the
instance with the given name and
group. |
List<String> |
getTriggerGroupNames()
Get the names of all known
groups. |
Set<TriggerKey> |
getTriggerKeys(GroupMatcher<TriggerKey> matcher)
Get the names of all the
in
the matching groups. |
List<? extends Trigger> |
getTriggersOfJob(JobKey jobKey)
|
Trigger.TriggerState |
getTriggerState(TriggerKey triggerKey)
Get the current state of the identified
. |
String |
getVersion() |
static String |
getVersionIteration() |
static String |
getVersionMajor() |
static String |
getVersionMinor() |
void |
initialize() |
boolean |
interrupt(JobKey jobKey)
Interrupt all instances of the identified InterruptableJob executing in
this Scheduler instance.
|
boolean |
interrupt(String fireInstanceId)
Interrupt the identified InterruptableJob executing in this Scheduler instance.
|
boolean |
isClustered() |
boolean |
isInStandbyMode()
Reports whether the
Scheduler is paused. |
boolean |
isShutdown()
Reports whether the
Scheduler has been shutdown. |
boolean |
isShuttingDown() |
boolean |
isSignalOnSchedulingChange() |
boolean |
isStarted() |
void |
notifyJobListenersToBeExecuted(JobExecutionContext jec) |
void |
notifyJobListenersWasExecuted(JobExecutionContext jec,
JobExecutionException je) |
void |
notifyJobListenersWasVetoed(JobExecutionContext jec) |
protected void |
notifyJobStoreJobComplete(OperableTrigger trigger,
JobDetail detail,
Trigger.CompletedExecutionInstruction instCode) |
protected void |
notifyJobStoreJobVetoed(OperableTrigger trigger,
JobDetail detail,
Trigger.CompletedExecutionInstruction instCode) |
void |
notifySchedulerListenersError(String msg,
SchedulerException se) |
void |
notifySchedulerListenersFinalized(Trigger trigger) |
void |
notifySchedulerListenersInStandbyMode() |
void |
notifySchedulerListenersJobAdded(JobDetail jobDetail) |
void |
notifySchedulerListenersJobDeleted(JobKey jobKey) |
void |
notifySchedulerListenersPausedJob(JobKey key) |
void |
notifySchedulerListenersPausedJobs(String group) |
void |
notifySchedulerListenersPausedTrigger(TriggerKey triggerKey) |
void |
notifySchedulerListenersPausedTriggers(String group) |
void |
notifySchedulerListenersResumedJob(JobKey key) |
void |
notifySchedulerListenersResumedJobs(String group) |
void |
notifySchedulerListenersResumedTrigger(TriggerKey key) |
void |
notifySchedulerListenersResumedTriggers(String group) |
void |
notifySchedulerListenersSchduled(Trigger trigger) |
void |
notifySchedulerListenersShutdown() |
void |
notifySchedulerListenersShuttingdown() |
void |
notifySchedulerListenersStarted() |
void |
notifySchedulerListenersStarting() |
void |
notifySchedulerListenersUnscheduled(TriggerKey triggerKey) |
protected void |
notifySchedulerThread(long candidateNewNextFireTime) |
void |
notifyTriggerListenersComplete(JobExecutionContext jec,
Trigger.CompletedExecutionInstruction instCode) |
boolean |
notifyTriggerListenersFired(JobExecutionContext jec) |
void |
notifyTriggerListenersMisfired(Trigger trigger) |
int |
numJobsExecuted() |
void |
pauseAll()
Pause all triggers - equivalent of calling
pauseTriggers(GroupMatcher
with a matcher matching all known groups. |
void |
pauseJob(JobKey jobKey)
Pause the
with the given
name - by pausing all of its current Trigger s. |
void |
pauseJobs(GroupMatcher<JobKey> groupMatcher)
Pause all of the
in the
matching groups - by pausing all of their Trigger s. |
void |
pauseTrigger(TriggerKey triggerKey)
Pause the
with the given name. |
void |
pauseTriggers(GroupMatcher<TriggerKey> matcher)
Pause all of the
in the matching groups. |
boolean |
removeInternalJobListener(String name)
Remove the identified
from the Scheduler 's
list of internal listeners. |
boolean |
removeInternalSchedulerListener(SchedulerListener schedulerListener)
Remove the given
from the
Scheduler 's list of internal listeners. |
boolean |
removeinternalTriggerListener(String name)
Remove the identified
from the Scheduler 's
list of internal listeners. |
boolean |
removeNoGCObject(Object obj) |
Date |
rescheduleJob(TriggerKey triggerKey,
Trigger newTrigger)
Remove (delete) the
with the
given name, and store the new given one - which must be associated
with the same job. |
void |
resetTriggerFromErrorState(TriggerKey triggerKey) |
void |
resumeAll()
Resume (un-pause) all triggers - equivalent of calling
resumeTriggerGroup(group)
on every group. |
void |
resumeJob(JobKey jobKey)
Resume (un-pause) the
with
the given name. |
void |
resumeJobs(GroupMatcher<JobKey> matcher)
Resume (un-pause) all of the
in the matching groups. |
void |
resumeTrigger(TriggerKey triggerKey)
Resume (un-pause) the
with the given
name. |
void |
resumeTriggers(GroupMatcher<TriggerKey> matcher)
Resume (un-pause) all of the
in the
matching groups. |
Date |
runningSince() |
void |
scheduleJob(JobDetail jobDetail,
Set<? extends Trigger> triggersForJob,
boolean replace) |
Date |
scheduleJob(JobDetail jobDetail,
Trigger trigger)
|
Date |
scheduleJob(Trigger trigger)
|
void |
scheduleJobs(Map<JobDetail,Set<? extends Trigger>> triggersAndJobs,
boolean replace) |
void |
setJobFactory(JobFactory factory) |
void |
setSignalOnSchedulingChange(boolean signalOnSchedulingChange) |
void |
shutdown()
Halts the
QuartzScheduler 's firing of ,
and cleans up all resources associated with the QuartzScheduler. |
void |
shutdown(boolean waitForJobsToComplete)
Halts the
QuartzScheduler 's firing of ,
and cleans up all resources associated with the QuartzScheduler. |
void |
standby()
Temporarily halts the
QuartzScheduler 's firing of . |
void |
start()
Starts the
QuartzScheduler 's threads that fire . |
void |
startDelayed(int seconds) |
boolean |
supportsPersistence() |
void |
triggerJob(JobKey jobKey,
JobDataMap data)
Trigger the identified
(execute it
now) - with a non-volatile trigger. |
void |
triggerJob(OperableTrigger trig)
Store and schedule the identified
|
boolean |
unscheduleJob(TriggerKey triggerKey)
Remove the indicated
from the
scheduler. |
boolean |
unscheduleJobs(List<TriggerKey> triggerKeys) |
void |
validateState() |
public QuartzScheduler(QuartzSchedulerResources resources, long idleWaitTime, @Deprecated long dbRetryInterval) throws SchedulerException
Create a QuartzScheduler
with the given configuration
properties.
SchedulerException
QuartzSchedulerResources
public void initialize() throws SchedulerException
SchedulerException
public String getVersion()
getVersion
in interface RemotableQuartzScheduler
public static String getVersionMajor()
public static String getVersionMinor()
public static String getVersionIteration()
public SchedulerSignaler getSchedulerSignaler()
public org.slf4j.Logger getLog()
public String getSchedulerName()
Returns the name of the QuartzScheduler
.
getSchedulerName
in interface RemotableQuartzScheduler
public String getSchedulerInstanceId()
Returns the instance Id of the QuartzScheduler
.
getSchedulerInstanceId
in interface RemotableQuartzScheduler
public ThreadGroup getSchedulerThreadGroup()
Returns the name of the thread group for Quartz's main threads.
public void addNoGCObject(Object obj)
public boolean removeNoGCObject(Object obj)
public SchedulerContext getSchedulerContext() throws SchedulerException
Returns the SchedulerContext
of the Scheduler
.
getSchedulerContext
in interface RemotableQuartzScheduler
SchedulerException
public boolean isSignalOnSchedulingChange()
public void setSignalOnSchedulingChange(boolean signalOnSchedulingChange)
public void start() throws SchedulerException
Starts the QuartzScheduler
's threads that fire
.
Trigger
s
All
that have misfired will
be passed to the appropriate TriggerListener(s).
Trigger
s
start
in interface RemotableQuartzScheduler
SchedulerException
public void startDelayed(int seconds) throws SchedulerException
startDelayed
in interface RemotableQuartzScheduler
SchedulerException
public void standby()
Temporarily halts the QuartzScheduler
's firing of
.
Trigger
s
The scheduler is not destroyed, and can be re-started at any time.
standby
in interface RemotableQuartzScheduler
public boolean isInStandbyMode()
Reports whether the Scheduler
is paused.
isInStandbyMode
in interface RemotableQuartzScheduler
public Date runningSince()
runningSince
in interface RemotableQuartzScheduler
public int numJobsExecuted()
numJobsExecuted
in interface RemotableQuartzScheduler
public Class<?> getJobStoreClass()
getJobStoreClass
in interface RemotableQuartzScheduler
public boolean supportsPersistence()
supportsPersistence
in interface RemotableQuartzScheduler
public boolean isClustered()
isClustered
in interface RemotableQuartzScheduler
public Class<?> getThreadPoolClass()
getThreadPoolClass
in interface RemotableQuartzScheduler
public int getThreadPoolSize()
getThreadPoolSize
in interface RemotableQuartzScheduler
public void shutdown()
Halts the QuartzScheduler
's firing of
,
and cleans up all resources associated with the QuartzScheduler.
Equivalent to Trigger
sshutdown(false)
.
The scheduler cannot be re-started.
shutdown
in interface RemotableQuartzScheduler
public void shutdown(boolean waitForJobsToComplete)
Halts the QuartzScheduler
's firing of
,
and cleans up all resources associated with the QuartzScheduler.
Trigger
s
The scheduler cannot be re-started.
shutdown
in interface RemotableQuartzScheduler
waitForJobsToComplete
- if true
the scheduler will not allow this method
to return until all currently executing jobs have completed.public boolean isShutdown()
Reports whether the Scheduler
has been shutdown.
isShutdown
in interface RemotableQuartzScheduler
public boolean isShuttingDown()
public boolean isStarted()
public void validateState() throws SchedulerException
SchedulerException
public List<JobExecutionContext> getCurrentlyExecutingJobs()
Return a list of JobExecutionContext
objects that
represent all currently executing Jobs in this Scheduler instance.
This method is not cluster aware. That is, it will only return Jobs currently executing in this Scheduler instance, not across the entire cluster.
Note that the list returned is an 'instantaneous' snap-shot, and that as soon as it's returned, the true list of executing jobs may be different.
getCurrentlyExecutingJobs
in interface RemotableQuartzScheduler
public Date scheduleJob(JobDetail jobDetail, Trigger trigger) throws SchedulerException
Add the
identified by the given
Job
to the Scheduler, and
associate the given JobDetail
with it.
Trigger
If the given Trigger does not reference any Job
, then it
will be set to reference the Job passed with it into this method.
scheduleJob
in interface RemotableQuartzScheduler
SchedulerException
- if the Job or Trigger cannot be added to the Scheduler, or
there is an internal Scheduler error.public Date scheduleJob(Trigger trigger) throws SchedulerException
Schedule the given
with the
Trigger
Job
identified by the Trigger
's settings.
scheduleJob
in interface RemotableQuartzScheduler
SchedulerException
- if the indicated Job does not exist, or the Trigger cannot be
added to the Scheduler, or there is an internal Scheduler
error.public void addJob(JobDetail jobDetail, boolean replace) throws SchedulerException
Add the given Job
to the Scheduler - with no associated
Trigger
. The Job
will be 'dormant' until
it is scheduled with a Trigger
, or Scheduler.triggerJob()
is called for it.
The Job
must by definition be 'durable', if it is not,
SchedulerException will be thrown.
addJob
in interface RemotableQuartzScheduler
SchedulerException
- if there is an internal Scheduler error, or if the Job is not
durable, or a Job with the same name already exists, and
replace
is false
.public void addJob(JobDetail jobDetail, boolean replace, boolean storeNonDurableWhileAwaitingScheduling) throws SchedulerException
addJob
in interface RemotableQuartzScheduler
SchedulerException
public boolean deleteJob(JobKey jobKey) throws SchedulerException
Delete the identified Job
from the Scheduler - and any
associated Trigger
s.
deleteJob
in interface RemotableQuartzScheduler
SchedulerException
- if there is an internal Scheduler error.public boolean deleteJobs(List<JobKey> jobKeys) throws SchedulerException
deleteJobs
in interface RemotableQuartzScheduler
SchedulerException
public void scheduleJobs(Map<JobDetail,Set<? extends Trigger>> triggersAndJobs, boolean replace) throws SchedulerException
scheduleJobs
in interface RemotableQuartzScheduler
SchedulerException
public void scheduleJob(JobDetail jobDetail, Set<? extends Trigger> triggersForJob, boolean replace) throws SchedulerException
scheduleJob
in interface RemotableQuartzScheduler
SchedulerException
public boolean unscheduleJobs(List<TriggerKey> triggerKeys) throws SchedulerException
unscheduleJobs
in interface RemotableQuartzScheduler
SchedulerException
public boolean unscheduleJob(TriggerKey triggerKey) throws SchedulerException
Remove the indicated
from the
scheduler.
Trigger
unscheduleJob
in interface RemotableQuartzScheduler
SchedulerException
public Date rescheduleJob(TriggerKey triggerKey, Trigger newTrigger) throws SchedulerException
Remove (delete) the
with the
given name, and store the new given one - which must be associated
with the same job.
Trigger
rescheduleJob
in interface RemotableQuartzScheduler
newTrigger
- The new Trigger
to be stored.null
if a Trigger
with the given
name & group was not found and removed from the store, otherwise
the first fire time of the newly scheduled trigger.SchedulerException
public void triggerJob(JobKey jobKey, JobDataMap data) throws SchedulerException
Trigger the identified
(execute it
now) - with a non-volatile trigger.
Job
triggerJob
in interface RemotableQuartzScheduler
SchedulerException
public void triggerJob(OperableTrigger trig) throws SchedulerException
Store and schedule the identified OperableTrigger
triggerJob
in interface RemotableQuartzScheduler
SchedulerException
public void pauseTrigger(TriggerKey triggerKey) throws SchedulerException
Pause the
with the given name.
Trigger
pauseTrigger
in interface RemotableQuartzScheduler
SchedulerException
public void pauseTriggers(GroupMatcher<TriggerKey> matcher) throws SchedulerException
Pause all of the
in the matching groups.
Trigger
s
pauseTriggers
in interface RemotableQuartzScheduler
SchedulerException
public void pauseJob(JobKey jobKey) throws SchedulerException
Pause the
with the given
name - by pausing all of its current JobDetail
Trigger
s.
pauseJob
in interface RemotableQuartzScheduler
SchedulerException
public void pauseJobs(GroupMatcher<JobKey> groupMatcher) throws SchedulerException
Pause all of the
in the
matching groups - by pausing all of their JobDetail
sTrigger
s.
pauseJobs
in interface RemotableQuartzScheduler
SchedulerException
public void resumeTrigger(TriggerKey triggerKey) throws SchedulerException
Resume (un-pause) the
with the given
name.
Trigger
If the Trigger
missed one or more fire-times, then the
Trigger
's misfire instruction will be applied.
resumeTrigger
in interface RemotableQuartzScheduler
SchedulerException
public void resumeTriggers(GroupMatcher<TriggerKey> matcher) throws SchedulerException
Resume (un-pause) all of the
in the
matching groups.
Trigger
s
If any Trigger
missed one or more fire-times, then the
Trigger
's misfire instruction will be applied.
resumeTriggers
in interface RemotableQuartzScheduler
SchedulerException
public Set<String> getPausedTriggerGroups() throws SchedulerException
getPausedTriggerGroups
in interface RemotableQuartzScheduler
SchedulerException
public void resumeJob(JobKey jobKey) throws SchedulerException
Resume (un-pause) the
with
the given name.
JobDetail
If any of the Job
'sTrigger
s missed one
or more fire-times, then the Trigger
's misfire
instruction will be applied.
resumeJob
in interface RemotableQuartzScheduler
SchedulerException
public void resumeJobs(GroupMatcher<JobKey> matcher) throws SchedulerException
Resume (un-pause) all of the
in the matching groups.
JobDetail
s
If any of the Job
s had Trigger
s that
missed one or more fire-times, then the Trigger
's
misfire instruction will be applied.
resumeJobs
in interface RemotableQuartzScheduler
SchedulerException
public void pauseAll() throws SchedulerException
Pause all triggers - equivalent of calling pauseTriggers(GroupMatcher
with a matcher matching all known groups.
When resumeAll()
is called (to un-pause), trigger misfire
instructions WILL be applied.
pauseAll
in interface RemotableQuartzScheduler
SchedulerException
resumeAll()
,
pauseTriggers(org.quartz.impl.matchers.GroupMatcher)
,
standby()
public void resumeAll() throws SchedulerException
Resume (un-pause) all triggers - equivalent of calling resumeTriggerGroup(group)
on every group.
If any Trigger
missed one or more fire-times, then the
Trigger
's misfire instruction will be applied.
resumeAll
in interface RemotableQuartzScheduler
SchedulerException
pauseAll()
public List<String> getJobGroupNames() throws SchedulerException
Get the names of all known
groups.
Job
getJobGroupNames
in interface RemotableQuartzScheduler
SchedulerException
public Set<JobKey> getJobKeys(GroupMatcher<JobKey> matcher) throws SchedulerException
Get the names of all the
in the
matching groups.
Job
s
getJobKeys
in interface RemotableQuartzScheduler
SchedulerException
public List<? extends Trigger> getTriggersOfJob(JobKey jobKey) throws SchedulerException
getTriggersOfJob
in interface RemotableQuartzScheduler
SchedulerException
public List<String> getTriggerGroupNames() throws SchedulerException
Get the names of all known
groups.
Trigger
getTriggerGroupNames
in interface RemotableQuartzScheduler
SchedulerException
public Set<TriggerKey> getTriggerKeys(GroupMatcher<TriggerKey> matcher) throws SchedulerException
Get the names of all the
in
the matching groups.
Trigger
s
getTriggerKeys
in interface RemotableQuartzScheduler
SchedulerException
public JobDetail getJobDetail(JobKey jobKey) throws SchedulerException
Get the
for the JobDetail
Job
instance with the given name and group.
getJobDetail
in interface RemotableQuartzScheduler
SchedulerException
public Trigger getTrigger(TriggerKey triggerKey) throws SchedulerException
Get the
instance with the given name and
group.
Trigger
getTrigger
in interface RemotableQuartzScheduler
SchedulerException
public boolean checkExists(JobKey jobKey) throws SchedulerException
Job
with the given identifier already
exists within the scheduler.checkExists
in interface RemotableQuartzScheduler
jobKey
- the identifier to check forSchedulerException
public boolean checkExists(TriggerKey triggerKey) throws SchedulerException
Trigger
with the given identifier already
exists within the scheduler.checkExists
in interface RemotableQuartzScheduler
triggerKey
- the identifier to check forSchedulerException
public void clear() throws SchedulerException
clear
in interface RemotableQuartzScheduler
SchedulerException
public Trigger.TriggerState getTriggerState(TriggerKey triggerKey) throws SchedulerException
Get the current state of the identified
.
Trigger
getTriggerState
in interface RemotableQuartzScheduler
SchedulerException
Trigger.TriggerState
public void resetTriggerFromErrorState(TriggerKey triggerKey) throws SchedulerException
resetTriggerFromErrorState
in interface RemotableQuartzScheduler
SchedulerException
public void addCalendar(String calName, Calendar calendar, boolean replace, boolean updateTriggers) throws SchedulerException
Add (register) the given Calendar
to the Scheduler.
addCalendar
in interface RemotableQuartzScheduler
SchedulerException
- if there is an internal Scheduler error, or a Calendar with
the same name already exists, and replace
is
false
.public boolean deleteCalendar(String calName) throws SchedulerException
Delete the identified Calendar
from the Scheduler.
deleteCalendar
in interface RemotableQuartzScheduler
SchedulerException
- if there is an internal Scheduler error.public Calendar getCalendar(String calName) throws SchedulerException
Get the
instance with the given name.
Calendar
getCalendar
in interface RemotableQuartzScheduler
SchedulerException
public List<String> getCalendarNames() throws SchedulerException
Get the names of all registered
.
Calendar
s
getCalendarNames
in interface RemotableQuartzScheduler
SchedulerException
public ListenerManager getListenerManager()
public void addInternalJobListener(JobListener jobListener)
Add the given
to the
JobListener
Scheduler
's internal list.
public boolean removeInternalJobListener(String name)
Remove the identified
from the JobListener
Scheduler
's
list of internal listeners.
public List<JobListener> getInternalJobListeners()
Get a List containing all of the
s
in the JobListener
Scheduler
's internal list.
public JobListener getInternalJobListener(String name)
Get the internal
that has the given name.
JobListener
public void addInternalTriggerListener(TriggerListener triggerListener)
Add the given
to the
TriggerListener
Scheduler
's internal list.
public boolean removeinternalTriggerListener(String name)
Remove the identified
from the TriggerListener
Scheduler
's
list of internal listeners.
public List<TriggerListener> getInternalTriggerListeners()
Get a list containing all of the
s
in the TriggerListener
Scheduler
's internal list.
public TriggerListener getInternalTriggerListener(String name)
Get the internal
that
has the given name.
TriggerListener
public void addInternalSchedulerListener(SchedulerListener schedulerListener)
Register the given
with the
SchedulerListener
Scheduler
's list of internal listeners.
public boolean removeInternalSchedulerListener(SchedulerListener schedulerListener)
Remove the given
from the
SchedulerListener
Scheduler
's list of internal listeners.
public List<SchedulerListener> getInternalSchedulerListeners()
Get a List containing all of the internal
s
registered with the SchedulerListener
Scheduler
.
protected void notifyJobStoreJobComplete(OperableTrigger trigger, JobDetail detail, Trigger.CompletedExecutionInstruction instCode)
protected void notifyJobStoreJobVetoed(OperableTrigger trigger, JobDetail detail, Trigger.CompletedExecutionInstruction instCode)
protected void notifySchedulerThread(long candidateNewNextFireTime)
public boolean notifyTriggerListenersFired(JobExecutionContext jec) throws SchedulerException
SchedulerException
public void notifyTriggerListenersMisfired(Trigger trigger) throws SchedulerException
SchedulerException
public void notifyTriggerListenersComplete(JobExecutionContext jec, Trigger.CompletedExecutionInstruction instCode) throws SchedulerException
SchedulerException
public void notifyJobListenersToBeExecuted(JobExecutionContext jec) throws SchedulerException
SchedulerException
public void notifyJobListenersWasVetoed(JobExecutionContext jec) throws SchedulerException
SchedulerException
public void notifyJobListenersWasExecuted(JobExecutionContext jec, JobExecutionException je) throws SchedulerException
SchedulerException
public void notifySchedulerListenersError(String msg, SchedulerException se)
public void notifySchedulerListenersSchduled(Trigger trigger)
public void notifySchedulerListenersUnscheduled(TriggerKey triggerKey)
public void notifySchedulerListenersFinalized(Trigger trigger)
public void notifySchedulerListenersPausedTrigger(TriggerKey triggerKey)
public void notifySchedulerListenersPausedTriggers(String group)
public void notifySchedulerListenersResumedTrigger(TriggerKey key)
public void notifySchedulerListenersResumedTriggers(String group)
public void notifySchedulerListenersPausedJob(JobKey key)
public void notifySchedulerListenersPausedJobs(String group)
public void notifySchedulerListenersResumedJob(JobKey key)
public void notifySchedulerListenersResumedJobs(String group)
public void notifySchedulerListenersInStandbyMode()
public void notifySchedulerListenersStarted()
public void notifySchedulerListenersStarting()
public void notifySchedulerListenersShutdown()
public void notifySchedulerListenersShuttingdown()
public void notifySchedulerListenersJobAdded(JobDetail jobDetail)
public void notifySchedulerListenersJobDeleted(JobKey jobKey)
public void setJobFactory(JobFactory factory) throws SchedulerException
SchedulerException
public JobFactory getJobFactory()
public boolean interrupt(JobKey jobKey) throws UnableToInterruptJobException
This method is not cluster aware. That is, it will only interrupt instances of the identified InterruptableJob currently executing in this Scheduler instance, not across the entire cluster.
interrupt
in interface RemotableQuartzScheduler
UnableToInterruptJobException
RemotableQuartzScheduler.interrupt(JobKey)
public boolean interrupt(String fireInstanceId) throws UnableToInterruptJobException
This method is not cluster aware. That is, it will only interrupt instances of the identified InterruptableJob currently executing in this Scheduler instance, not across the entire cluster.
interrupt
in interface RemotableQuartzScheduler
UnableToInterruptJobException
RemotableQuartzScheduler.interrupt(JobKey)
Copyright 2001-2019, Terracotta, Inc.