public class QuartzSchedulerMBeanImpl extends StandardMBean implements NotificationEmitter, QuartzSchedulerMBean, JobListener, SchedulerListener
Modifier and Type | Field and Description |
---|---|
protected org.quartz.core.QuartzSchedulerMBeanImpl.Emitter |
emitter
emitter
|
protected AtomicLong |
sequenceNumber
sequenceNumber
|
JOB_ADDED, JOB_DELETED, JOB_EXECUTION_VETOED, JOB_SCHEDULED, JOB_TO_BE_EXECUTED, JOB_UNSCHEDULED, JOB_WAS_EXECUTED, JOBS_PAUSED, JOBS_RESUMED, SAMPLED_STATISTICS_ENABLED, SAMPLED_STATISTICS_RESET, SCHEDULER_ERROR, SCHEDULER_PAUSED, SCHEDULER_SHUTDOWN, SCHEDULER_STARTED, SCHEDULING_DATA_CLEARED, TRIGGER_FINALIZED, TRIGGERS_PAUSED, TRIGGERS_RESUMED
Modifier | Constructor and Description |
---|---|
protected |
QuartzSchedulerMBeanImpl(QuartzScheduler scheduler)
QuartzSchedulerMBeanImpl
|
Modifier and Type | Method and Description |
---|---|
void |
addJob(CompositeData jobDetail,
boolean replace) |
void |
addJob(Map<String,Object> abstractJobInfo,
boolean replace)
Adds a durable job described by abstractJobInfo, which must contain the fully-qualified JobDetail
class name under the key "jobDetailClass." That JobDetail type must contain a no-arg constructor
and have public access.
|
void |
addNotificationListener(NotificationListener notif,
NotificationFilter filter,
Object callBack) |
void |
clear() |
void |
deleteCalendar(String calendarName) |
boolean |
deleteJob(String jobName,
String jobGroupName) |
TabularData |
getAllJobDetails() |
List<CompositeData> |
getAllTriggers() |
List<String> |
getCalendarNames() |
TabularData |
getCurrentlyExecutingJobs() |
CompositeData |
getJobDetail(String jobName,
String jobGroupName) |
List<String> |
getJobGroupNames() |
List<String> |
getJobNames(String groupName) |
long |
getJobsCompletedMostRecentSample() |
long |
getJobsExecutedMostRecentSample() |
long |
getJobsScheduledMostRecentSample() |
String |
getJobStoreClassName() |
String |
getName()
Get the name of the
JobListener . |
MBeanNotificationInfo[] |
getNotificationInfo() |
Set<String> |
getPausedTriggerGroups() |
Map<String,Long> |
getPerformanceMetrics() |
String |
getSchedulerInstanceId() |
String |
getSchedulerName() |
String |
getThreadPoolClassName() |
int |
getThreadPoolSize() |
CompositeData |
getTrigger(String name,
String groupName) |
List<String> |
getTriggerGroupNames() |
List<String> |
getTriggerNames(String groupName) |
List<CompositeData> |
getTriggersOfJob(String jobName,
String jobGroupName) |
String |
getTriggerState(String triggerName,
String triggerGroupName) |
String |
getVersion() |
boolean |
interruptJob(String fireInstanceId) |
boolean |
interruptJob(String jobName,
String jobGroupName) |
boolean |
isSampledStatisticsEnabled() |
boolean |
isShutdown() |
boolean |
isStandbyMode() |
boolean |
isStarted() |
void |
jobAdded(JobDetail jobDetail)
|
void |
jobDeleted(JobKey jobKey)
|
void |
jobExecutionVetoed(JobExecutionContext context)
Called by the
when a
was about to be executed (an associated
has occurred), but a vetoed it's
execution. |
void |
jobPaused(JobKey jobKey)
|
void |
jobResumed(JobKey jobKey)
|
void |
jobScheduled(Trigger trigger)
|
void |
jobsPaused(String jobGroup)
|
void |
jobsResumed(String jobGroup)
|
void |
jobToBeExecuted(JobExecutionContext context)
|
void |
jobUnscheduled(TriggerKey triggerKey)
|
void |
jobWasExecuted(JobExecutionContext context,
JobExecutionException jobException)
|
void |
pauseAllTriggers() |
void |
pauseJob(String jobName,
String jobGroup) |
void |
pauseJobGroup(String jobGroup) |
void |
pauseJobs(GroupMatcher<JobKey> matcher) |
void |
pauseJobsAll()
Pause all jobs whose group is anything
|
void |
pauseJobsContaining(String jobGroupToken)
Pause all jobs whose group contains jobGroupToken
|
void |
pauseJobsEndingWith(String jobGroupSuffix)
Pause all jobs whose group ends with jobGroupSuffix
|
void |
pauseJobsStartingWith(String jobGroupPrefix)
Pause all jobs whose group starts with jobGroupPrefix
|
void |
pauseTrigger(String triggerName,
String triggerGroup) |
void |
pauseTriggerGroup(String triggerGroup) |
void |
pauseTriggersAll()
Pause all triggers whose group is anything
|
void |
pauseTriggersContaining(String triggerGroupToken)
Pause all triggers whose group contains triggerGroupToken
|
void |
pauseTriggersEndingWith(String triggerGroupSuffix)
Pause all triggers whose group ends with triggerGroupSuffix
|
void |
pauseTriggersStartingWith(String triggerGroupPrefix)
Pause all triggers whose group starts with triggerGroupPrefix
|
void |
removeNotificationListener(NotificationListener listener) |
void |
removeNotificationListener(NotificationListener notif,
NotificationFilter filter,
Object callBack) |
void |
resumeAllTriggers() |
void |
resumeJob(String jobName,
String jobGroup) |
void |
resumeJobGroup(String jobGroup)
Resume all jobs in the given group
|
void |
resumeJobs(GroupMatcher<JobKey> matcher) |
void |
resumeJobsAll()
Resume all jobs whose group is anything
|
void |
resumeJobsContaining(String jobGroupToken)
Resume all jobs whose group contains jobGroupToken
|
void |
resumeJobsEndingWith(String jobGroupSuffix)
Resume all jobs whose group ends with jobGroupSuffix
|
void |
resumeJobsStartingWith(String jobGroupPrefix)
Resume all jobs whose group starts with jobGroupPrefix
|
void |
resumeTrigger(String triggerName,
String triggerGroup) |
void |
resumeTriggerGroup(String triggerGroup) |
void |
resumeTriggersAll()
Resume all triggers whose group is anything
|
void |
resumeTriggersContaining(String triggerGroupToken)
Resume all triggers whose group contains triggerGroupToken
|
void |
resumeTriggersEndingWith(String triggerGroupSuffix)
Resume all triggers whose group ends with triggerGroupSuffix
|
void |
resumeTriggersStartingWith(String triggerGroupPrefix)
Resume all triggers whose group starts with triggerGroupPrefix
|
void |
scheduleBasicJob(Map<String,Object> jobDetailInfo,
Map<String,Object> triggerInfo)
Schedules a job using the given Cron/Simple triggerInfo.
|
void |
scheduleJob(Map<String,Object> abstractJobInfo,
Map<String,Object> abstractTriggerInfo)
Schedules an arbitrary job described by abstractJobInfo using a trigger specified by abstractTriggerInfo.
|
void |
scheduleJob(String jobName,
String jobGroup,
Map<String,Object> abstractTriggerInfo)
Schedules the specified job using a trigger described by abstractTriggerInfo, which must contain the
fully-qualified trigger class name under the key "triggerClass." That trigger type must contain a
no-arg constructor and have public access.
|
Date |
scheduleJob(String jobName,
String jobGroup,
String triggerName,
String triggerGroup)
Schedule an existing job with an existing trigger.
|
void |
schedulerError(String msg,
SchedulerException cause)
Called by the
when a serious error has
occurred within the scheduler - such as repeated failures in the JobStore ,
or the inability to instantiate a Job instance when its
Trigger has fired. |
void |
schedulerInStandbyMode()
Called by the
to inform the listener
that it has move to standby mode. |
void |
schedulerShutdown()
Called by the
to inform the listener
that it has shutdown. |
void |
schedulerShuttingdown()
Called by the
to inform the listener
that it has begun the shutdown sequence. |
void |
schedulerStarted()
Called by the
to inform the listener
that it has started. |
void |
schedulerStarting()
Called by the
to inform the listener
that it is starting. |
void |
schedulingDataCleared()
Called by the
to inform the listener
that all jobs, triggers and calendars were deleted. |
void |
sendNotification(String eventType)
sendNotification
|
void |
sendNotification(String eventType,
Object data)
sendNotification
|
void |
sendNotification(String eventType,
Object data,
String msg)
sendNotification
|
void |
setSampledStatisticsEnabled(boolean enabled) |
void |
shutdown() |
void |
standby() |
void |
start() |
void |
triggerFinalized(Trigger trigger)
|
void |
triggerJob(CompositeData trigger) |
void |
triggerJob(String jobName,
String jobGroup,
Map<String,String> jobDataMap) |
void |
triggerPaused(TriggerKey triggerKey)
|
void |
triggerResumed(TriggerKey triggerKey)
|
void |
triggersPaused(String triggerGroup)
|
void |
triggersResumed(String triggerGroup)
|
boolean |
unscheduleJob(String triggerName,
String triggerGroup) |
cacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInfo, getMBeanInterface, getParameterName, getParameterName, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementation
protected final org.quartz.core.QuartzSchedulerMBeanImpl.Emitter emitter
protected final AtomicLong sequenceNumber
protected QuartzSchedulerMBeanImpl(QuartzScheduler scheduler) throws NotCompliantMBeanException
NotCompliantMBeanException
public TabularData getCurrentlyExecutingJobs() throws Exception
getCurrentlyExecutingJobs
in interface QuartzSchedulerMBean
Exception
public TabularData getAllJobDetails() throws Exception
getAllJobDetails
in interface QuartzSchedulerMBean
Exception
JobDetailSupport
public List<CompositeData> getAllTriggers() throws Exception
getAllTriggers
in interface QuartzSchedulerMBean
Exception
TriggerSupport
public void addJob(CompositeData jobDetail, boolean replace) throws Exception
addJob
in interface QuartzSchedulerMBean
Exception
public void scheduleBasicJob(Map<String,Object> jobDetailInfo, Map<String,Object> triggerInfo) throws Exception
QuartzSchedulerMBean
scheduleBasicJob
in interface QuartzSchedulerMBean
Exception
public void scheduleJob(Map<String,Object> abstractJobInfo, Map<String,Object> abstractTriggerInfo) throws Exception
QuartzSchedulerMBean
scheduleJob
in interface QuartzSchedulerMBean
Exception
public void scheduleJob(String jobName, String jobGroup, Map<String,Object> abstractTriggerInfo) throws Exception
QuartzSchedulerMBean
scheduleJob
in interface QuartzSchedulerMBean
Exception
public void addJob(Map<String,Object> abstractJobInfo, boolean replace) throws Exception
QuartzSchedulerMBean
addJob
in interface QuartzSchedulerMBean
abstractJobInfo
- map of attributes defining jobreplace
- whether or not to replace a pre-existing job with the same keyException
public void deleteCalendar(String calendarName) throws Exception
deleteCalendar
in interface QuartzSchedulerMBean
Exception
public boolean deleteJob(String jobName, String jobGroupName) throws Exception
deleteJob
in interface QuartzSchedulerMBean
Exception
public List<String> getCalendarNames() throws Exception
getCalendarNames
in interface QuartzSchedulerMBean
Exception
public CompositeData getJobDetail(String jobName, String jobGroupName) throws Exception
getJobDetail
in interface QuartzSchedulerMBean
Exception
JobDetailSupport
public List<String> getJobGroupNames() throws Exception
getJobGroupNames
in interface QuartzSchedulerMBean
Exception
public List<String> getJobNames(String groupName) throws Exception
getJobNames
in interface QuartzSchedulerMBean
Exception
public String getJobStoreClassName()
getJobStoreClassName
in interface QuartzSchedulerMBean
public Set<String> getPausedTriggerGroups() throws Exception
getPausedTriggerGroups
in interface QuartzSchedulerMBean
Exception
public CompositeData getTrigger(String name, String groupName) throws Exception
getTrigger
in interface QuartzSchedulerMBean
Exception
public List<String> getTriggerGroupNames() throws Exception
getTriggerGroupNames
in interface QuartzSchedulerMBean
Exception
public List<String> getTriggerNames(String groupName) throws Exception
getTriggerNames
in interface QuartzSchedulerMBean
Exception
public String getTriggerState(String triggerName, String triggerGroupName) throws Exception
getTriggerState
in interface QuartzSchedulerMBean
Exception
public List<CompositeData> getTriggersOfJob(String jobName, String jobGroupName) throws Exception
getTriggersOfJob
in interface QuartzSchedulerMBean
Exception
TriggerSupport
public boolean interruptJob(String jobName, String jobGroupName) throws Exception
interruptJob
in interface QuartzSchedulerMBean
Exception
public boolean interruptJob(String fireInstanceId) throws Exception
interruptJob
in interface QuartzSchedulerMBean
Exception
public Date scheduleJob(String jobName, String jobGroup, String triggerName, String triggerGroup) throws Exception
QuartzSchedulerMBean
scheduleJob
in interface QuartzSchedulerMBean
Exception
public boolean unscheduleJob(String triggerName, String triggerGroup) throws Exception
unscheduleJob
in interface QuartzSchedulerMBean
Exception
public void clear() throws Exception
clear
in interface QuartzSchedulerMBean
Exception
public String getVersion()
getVersion
in interface QuartzSchedulerMBean
public boolean isShutdown()
isShutdown
in interface QuartzSchedulerMBean
public boolean isStarted()
isStarted
in interface QuartzSchedulerMBean
public void start() throws Exception
start
in interface QuartzSchedulerMBean
Exception
public void shutdown()
shutdown
in interface QuartzSchedulerMBean
public void standby()
standby
in interface QuartzSchedulerMBean
public boolean isStandbyMode()
isStandbyMode
in interface QuartzSchedulerMBean
public String getSchedulerName()
getSchedulerName
in interface QuartzSchedulerMBean
public String getSchedulerInstanceId()
getSchedulerInstanceId
in interface QuartzSchedulerMBean
public String getThreadPoolClassName()
getThreadPoolClassName
in interface QuartzSchedulerMBean
public int getThreadPoolSize()
getThreadPoolSize
in interface QuartzSchedulerMBean
public void pauseJob(String jobName, String jobGroup) throws Exception
pauseJob
in interface QuartzSchedulerMBean
Exception
public void pauseJobs(GroupMatcher<JobKey> matcher) throws Exception
Exception
public void pauseJobGroup(String jobGroup) throws Exception
pauseJobGroup
in interface QuartzSchedulerMBean
Exception
public void pauseJobsStartingWith(String jobGroupPrefix) throws Exception
QuartzSchedulerMBean
pauseJobsStartingWith
in interface QuartzSchedulerMBean
Exception
public void pauseJobsEndingWith(String jobGroupSuffix) throws Exception
QuartzSchedulerMBean
pauseJobsEndingWith
in interface QuartzSchedulerMBean
Exception
public void pauseJobsContaining(String jobGroupToken) throws Exception
QuartzSchedulerMBean
pauseJobsContaining
in interface QuartzSchedulerMBean
Exception
public void pauseJobsAll() throws Exception
QuartzSchedulerMBean
pauseJobsAll
in interface QuartzSchedulerMBean
Exception
public void pauseAllTriggers() throws Exception
pauseAllTriggers
in interface QuartzSchedulerMBean
Exception
public void pauseTriggerGroup(String triggerGroup) throws Exception
pauseTriggerGroup
in interface QuartzSchedulerMBean
Exception
public void pauseTriggersStartingWith(String triggerGroupPrefix) throws Exception
QuartzSchedulerMBean
pauseTriggersStartingWith
in interface QuartzSchedulerMBean
Exception
public void pauseTriggersEndingWith(String triggerGroupSuffix) throws Exception
QuartzSchedulerMBean
pauseTriggersEndingWith
in interface QuartzSchedulerMBean
Exception
public void pauseTriggersContaining(String triggerGroupToken) throws Exception
QuartzSchedulerMBean
pauseTriggersContaining
in interface QuartzSchedulerMBean
Exception
public void pauseTriggersAll() throws Exception
QuartzSchedulerMBean
pauseTriggersAll
in interface QuartzSchedulerMBean
Exception
public void pauseTrigger(String triggerName, String triggerGroup) throws Exception
pauseTrigger
in interface QuartzSchedulerMBean
Exception
public void resumeAllTriggers() throws Exception
resumeAllTriggers
in interface QuartzSchedulerMBean
Exception
public void resumeJob(String jobName, String jobGroup) throws Exception
resumeJob
in interface QuartzSchedulerMBean
Exception
public void resumeJobs(GroupMatcher<JobKey> matcher) throws Exception
Exception
public void resumeJobGroup(String jobGroup) throws Exception
QuartzSchedulerMBean
resumeJobGroup
in interface QuartzSchedulerMBean
Exception
public void resumeJobsStartingWith(String jobGroupPrefix) throws Exception
QuartzSchedulerMBean
resumeJobsStartingWith
in interface QuartzSchedulerMBean
Exception
public void resumeJobsEndingWith(String jobGroupSuffix) throws Exception
QuartzSchedulerMBean
resumeJobsEndingWith
in interface QuartzSchedulerMBean
Exception
public void resumeJobsContaining(String jobGroupToken) throws Exception
QuartzSchedulerMBean
resumeJobsContaining
in interface QuartzSchedulerMBean
Exception
public void resumeJobsAll() throws Exception
QuartzSchedulerMBean
resumeJobsAll
in interface QuartzSchedulerMBean
Exception
public void resumeTrigger(String triggerName, String triggerGroup) throws Exception
resumeTrigger
in interface QuartzSchedulerMBean
Exception
public void resumeTriggerGroup(String triggerGroup) throws Exception
resumeTriggerGroup
in interface QuartzSchedulerMBean
Exception
public void resumeTriggersStartingWith(String triggerGroupPrefix) throws Exception
QuartzSchedulerMBean
resumeTriggersStartingWith
in interface QuartzSchedulerMBean
Exception
public void resumeTriggersEndingWith(String triggerGroupSuffix) throws Exception
QuartzSchedulerMBean
resumeTriggersEndingWith
in interface QuartzSchedulerMBean
Exception
public void resumeTriggersContaining(String triggerGroupToken) throws Exception
QuartzSchedulerMBean
resumeTriggersContaining
in interface QuartzSchedulerMBean
Exception
public void resumeTriggersAll() throws Exception
QuartzSchedulerMBean
resumeTriggersAll
in interface QuartzSchedulerMBean
Exception
public void triggerJob(String jobName, String jobGroup, Map<String,String> jobDataMap) throws Exception
triggerJob
in interface QuartzSchedulerMBean
Exception
public void triggerJob(CompositeData trigger) throws Exception
Exception
public void jobAdded(JobDetail jobDetail)
SchedulerListener
jobAdded
in interface SchedulerListener
public void jobDeleted(JobKey jobKey)
SchedulerListener
jobDeleted
in interface SchedulerListener
public void jobScheduled(Trigger trigger)
SchedulerListener
jobScheduled
in interface SchedulerListener
public void jobUnscheduled(TriggerKey triggerKey)
SchedulerListener
jobUnscheduled
in interface SchedulerListener
SchedulerListener.schedulingDataCleared()
public void schedulingDataCleared()
SchedulerListener
Scheduler
to inform the listener
that all jobs, triggers and calendars were deleted.schedulingDataCleared
in interface SchedulerListener
public void jobPaused(JobKey jobKey)
SchedulerListener
jobPaused
in interface SchedulerListener
public void jobsPaused(String jobGroup)
SchedulerListener
jobsPaused
in interface SchedulerListener
jobGroup
- the paused group, or null if all were pausedpublic void jobsResumed(String jobGroup)
SchedulerListener
jobsResumed
in interface SchedulerListener
public void jobResumed(JobKey jobKey)
SchedulerListener
jobResumed
in interface SchedulerListener
public void schedulerError(String msg, SchedulerException cause)
SchedulerListener
Called by the
when a serious error has
occurred within the scheduler - such as repeated failures in the Scheduler
JobStore
,
or the inability to instantiate a Job
instance when its
Trigger
has fired.
The getErrorCode()
method of the given SchedulerException
can be used to determine more specific information about the type of
error that was encountered.
schedulerError
in interface SchedulerListener
public void schedulerStarted()
SchedulerListener
Called by the
to inform the listener
that it has started.
Scheduler
schedulerStarted
in interface SchedulerListener
public void schedulerStarting()
SchedulerListener
Called by the
to inform the listener
that it is starting.
Scheduler
schedulerStarting
in interface SchedulerListener
public void schedulerInStandbyMode()
SchedulerListener
Called by the
to inform the listener
that it has move to standby mode.
Scheduler
schedulerInStandbyMode
in interface SchedulerListener
public void schedulerShutdown()
SchedulerListener
Called by the
to inform the listener
that it has shutdown.
Scheduler
schedulerShutdown
in interface SchedulerListener
public void schedulerShuttingdown()
SchedulerListener
Called by the
to inform the listener
that it has begun the shutdown sequence.
Scheduler
schedulerShuttingdown
in interface SchedulerListener
public void triggerFinalized(Trigger trigger)
SchedulerListener
triggerFinalized
in interface SchedulerListener
public void triggersPaused(String triggerGroup)
SchedulerListener
Called by the
when a
group of Scheduler
has been paused.
Trigger
s
If all groups were paused then triggerGroup will be null
triggersPaused
in interface SchedulerListener
triggerGroup
- the paused group, or null if all were pausedpublic void triggerPaused(TriggerKey triggerKey)
SchedulerListener
triggerPaused
in interface SchedulerListener
public void triggersResumed(String triggerGroup)
SchedulerListener
triggersResumed
in interface SchedulerListener
public void triggerResumed(TriggerKey triggerKey)
SchedulerListener
triggerResumed
in interface SchedulerListener
public String getName()
JobListener
Get the name of the JobListener
.
getName
in interface JobListener
public void jobExecutionVetoed(JobExecutionContext context)
JobListener
Called by the
when a Scheduler
was about to be executed (an associated JobDetail
has occurred), but a Trigger
vetoed it's
execution.
TriggerListener
jobExecutionVetoed
in interface JobListener
JobListener.jobToBeExecuted(JobExecutionContext)
public void jobToBeExecuted(JobExecutionContext context)
JobListener
Called by the
when a Scheduler
is about to be executed (an associated JobDetail
has occurred).
Trigger
This method will not be invoked if the execution of the Job was vetoed
by a
.
TriggerListener
jobToBeExecuted
in interface JobListener
JobListener.jobExecutionVetoed(JobExecutionContext)
public void jobWasExecuted(JobExecutionContext context, JobExecutionException jobException)
JobListener
Called by the
after a Scheduler
has been executed, and be for the associated JobDetail
Trigger
's
triggered(xx)
method has been called.
jobWasExecuted
in interface JobListener
public void sendNotification(String eventType)
eventType
- public void sendNotification(String eventType, Object data)
eventType
- data
- public void sendNotification(String eventType, Object data, String msg)
eventType
- data
- msg
- public void addNotificationListener(NotificationListener notif, NotificationFilter filter, Object callBack)
public MBeanNotificationInfo[] getNotificationInfo()
getNotificationInfo
in interface NotificationBroadcaster
NotificationBroadcaster.getNotificationInfo()
public void removeNotificationListener(NotificationListener listener) throws ListenerNotFoundException
removeNotificationListener
in interface NotificationBroadcaster
ListenerNotFoundException
NotificationBroadcaster.removeNotificationListener(javax.management.NotificationListener)
public void removeNotificationListener(NotificationListener notif, NotificationFilter filter, Object callBack) throws ListenerNotFoundException
public boolean isSampledStatisticsEnabled()
isSampledStatisticsEnabled
in interface QuartzSchedulerMBean
public void setSampledStatisticsEnabled(boolean enabled)
setSampledStatisticsEnabled
in interface QuartzSchedulerMBean
public long getJobsCompletedMostRecentSample()
getJobsCompletedMostRecentSample
in interface QuartzSchedulerMBean
public long getJobsExecutedMostRecentSample()
getJobsExecutedMostRecentSample
in interface QuartzSchedulerMBean
public long getJobsScheduledMostRecentSample()
getJobsScheduledMostRecentSample
in interface QuartzSchedulerMBean
public Map<String,Long> getPerformanceMetrics()
getPerformanceMetrics
in interface QuartzSchedulerMBean
Copyright 2001-2019, Terracotta, Inc.