|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object javax.management.StandardMBean org.quartz.core.QuartzSchedulerMBeanImpl
public class QuartzSchedulerMBeanImpl
Field Summary | |
---|---|
protected org.quartz.core.QuartzSchedulerMBeanImpl.Emitter |
emitter
emitter |
protected java.util.concurrent.atomic.AtomicLong |
sequenceNumber
sequenceNumber |
Fields inherited from interface org.quartz.core.jmx.QuartzSchedulerMBean |
---|
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, TRIGGER_FINALIZED, TRIGGERS_PAUSED, TRIGGERS_RESUMED |
Constructor Summary | |
---|---|
protected |
QuartzSchedulerMBeanImpl(QuartzScheduler scheduler)
QuartzSchedulerMBeanImpl |
Method Summary | |
---|---|
void |
addJob(java.lang.String instanceId,
javax.management.openmbean.CompositeData jobDetail,
boolean replace)
|
void |
addNotificationListener(javax.management.NotificationListener notif,
javax.management.NotificationFilter filter,
java.lang.Object callBack)
|
void |
deleteCalendar(java.lang.String instanceId,
java.lang.String name)
|
boolean |
deleteJob(java.lang.String instanceId,
java.lang.String jobName,
java.lang.String jobGroupName)
|
javax.management.openmbean.TabularData |
getAllJobDetails(java.lang.String instanceId)
|
javax.management.openmbean.TabularData |
getAllTriggers(java.lang.String instanceId)
|
java.lang.String[] |
getCalendarNames(java.lang.String instanceId)
|
javax.management.openmbean.TabularData |
getCurrentlyExecutingJobs()
|
javax.management.openmbean.CompositeData |
getJobDetail(java.lang.String instanceId,
java.lang.String jobName,
java.lang.String jobGroupName)
|
java.lang.String[] |
getJobGroupNames(java.lang.String instanceId)
|
java.lang.String[] |
getJobNames(java.lang.String instanceId,
java.lang.String groupName)
|
long |
getJobsCompletedMostRecentSample()
|
long |
getJobsExecutedMostRecentSample()
|
long |
getJobsScheduledMostRecentSample()
|
java.lang.String |
getJobStoreClassName()
|
java.lang.String |
getName()
Get the name of the JobListener . |
javax.management.MBeanNotificationInfo[] |
getNotificationInfo()
|
java.util.Set<java.lang.String> |
getPausedTriggerGroups(java.lang.String instanceId)
|
java.util.Map<java.lang.String,java.lang.Long> |
getPerformanceMetrics()
|
java.lang.String |
getSchedulerInstanceId()
|
java.lang.String |
getSchedulerName()
|
java.lang.String |
getThreadPoolClassName()
|
int |
getThreadPoolSize()
|
javax.management.openmbean.CompositeData |
getTrigger(java.lang.String instanceId,
java.lang.String triggerName,
java.lang.String triggerGroupName)
|
java.lang.String[] |
getTriggerGroupNames(java.lang.String instanceId)
|
java.lang.String[] |
getTriggerNames(java.lang.String instanceId,
java.lang.String triggerGroupName)
|
javax.management.openmbean.TabularData |
getTriggersOfJob(java.lang.String instanceId,
java.lang.String jobName,
java.lang.String jobGroupName)
|
int |
getTriggerState(java.lang.String instanceId,
java.lang.String triggerName,
java.lang.String triggerGroupName)
|
java.lang.String |
getVersion()
|
boolean |
interruptJob(java.lang.String instanceId,
java.lang.String jobName,
java.lang.String jobGroupName)
|
boolean |
isSampledStatisticsEnabled()
|
boolean |
isShutdown()
|
boolean |
isStandbyMode()
|
boolean |
isStarted()
|
void |
jobAdded(JobDetail jobDetail)
Called by the when a
has been added. |
void |
jobDeleted(java.lang.String jobName,
java.lang.String groupName)
Called by the when a
has been deleted. |
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 |
jobScheduled(Trigger trigger)
Called by the when a
is scheduled. |
void |
jobsPaused(java.lang.String jobName,
java.lang.String jobGroup)
Called by the when a
or group of has been
paused. |
void |
jobsResumed(java.lang.String jobName,
java.lang.String jobGroup)
Called by the when a
or group of has been
un-paused. |
void |
jobToBeExecuted(JobExecutionContext context)
Called by the when a
is about to be executed (an associated
has occurred). |
void |
jobUnscheduled(java.lang.String triggerName,
java.lang.String triggerGroup)
Called by the when a
is unscheduled. |
void |
jobWasExecuted(JobExecutionContext context,
JobExecutionException jobException)
Called by the after a
has been executed, and be for the associated Trigger 's
triggered(xx) method has been called. |
void |
pauseAllTriggers(java.lang.String instanceId)
|
void |
pauseJob(java.lang.String instanceId,
java.lang.String jobName,
java.lang.String groupName)
|
void |
pauseJobGroup(java.lang.String instanceId,
java.lang.String jobGroupName)
|
void |
pauseTrigger(java.lang.String instanceId,
java.lang.String triggerName,
java.lang.String triggerGroup)
|
void |
pauseTriggerGroup(java.lang.String instanceId,
java.lang.String groupName)
|
void |
removeNotificationListener(javax.management.NotificationListener listener)
|
void |
removeNotificationListener(javax.management.NotificationListener notif,
javax.management.NotificationFilter filter,
java.lang.Object callBack)
|
void |
resumeAllTriggers(java.lang.String instanceId)
|
void |
resumeJob(java.lang.String instanceId,
java.lang.String jobName,
java.lang.String jobGroupName)
|
void |
resumeJobGroup(java.lang.String instanceId,
java.lang.String jobGroupName)
|
void |
resumeTrigger(java.lang.String instanceId,
java.lang.String triggerName,
java.lang.String triggerGroupName)
|
void |
resumeTriggerGroup(java.lang.String instanceId,
java.lang.String groupName)
|
java.util.Date |
scheduleJob(java.lang.String instanceId,
java.lang.String jobName,
java.lang.String jobGroup,
java.lang.String triggerName,
java.lang.String triggerGroup)
|
void |
schedulerError(java.lang.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 process. |
void |
schedulerStarted()
Called by the to inform the listener
that it has started. |
void |
sendNotification(java.lang.String eventType)
sendNotification |
void |
sendNotification(java.lang.String eventType,
java.lang.Object data)
sendNotification |
void |
sendNotification(java.lang.String eventType,
java.lang.Object data,
java.lang.String msg)
sendNotification |
void |
setSampledStatisticsEnabled(boolean enabled)
|
void |
shutdown()
|
void |
standby()
|
void |
start()
|
void |
triggerFinalized(Trigger trigger)
Called by the when a
has reached the condition in which it will never fire again. |
void |
triggerJob(java.lang.String instanceId,
java.lang.String jobName,
java.lang.String jobGroupName,
java.util.Map<java.lang.String,java.lang.String> jobDataMap)
|
void |
triggerJobWithVolatileTrigger(java.lang.String instanceId,
java.lang.String jobName,
java.lang.String jobGroupName,
java.util.Map<java.lang.String,java.lang.String> jobDataMap)
|
void |
triggersPaused(java.lang.String triggerName,
java.lang.String triggerGroup)
Called by the when a
or group of has been paused. |
void |
triggersResumed(java.lang.String triggerName,
java.lang.String triggerGroup)
Called by the when a
or group of has been un-paused. |
boolean |
unscheduleJob(java.lang.String instanceId,
java.lang.String triggerName,
java.lang.String triggerGroup)
|
Methods inherited from class javax.management.StandardMBean |
---|
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 |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected final org.quartz.core.QuartzSchedulerMBeanImpl.Emitter emitter
protected final java.util.concurrent.atomic.AtomicLong sequenceNumber
Constructor Detail |
---|
protected QuartzSchedulerMBeanImpl(QuartzScheduler scheduler) throws javax.management.NotCompliantMBeanException
javax.management.NotCompliantMBeanException
Method Detail |
---|
public javax.management.openmbean.TabularData getCurrentlyExecutingJobs() throws SchedulerException
getCurrentlyExecutingJobs
in interface QuartzSchedulerMBean
SchedulerException
public javax.management.openmbean.TabularData getAllJobDetails(java.lang.String instanceId) throws SchedulerException
getAllJobDetails
in interface QuartzSchedulerMBean
SchedulerException
JobDetailSupport
public javax.management.openmbean.TabularData getAllTriggers(java.lang.String instanceId) throws SchedulerException
getAllTriggers
in interface QuartzSchedulerMBean
SchedulerException
TriggerSupport
public void addJob(java.lang.String instanceId, javax.management.openmbean.CompositeData jobDetail, boolean replace) throws SchedulerException
addJob
in interface QuartzSchedulerMBean
SchedulerException
public void deleteCalendar(java.lang.String instanceId, java.lang.String name) throws SchedulerException
deleteCalendar
in interface QuartzSchedulerMBean
SchedulerException
public boolean deleteJob(java.lang.String instanceId, java.lang.String jobName, java.lang.String jobGroupName) throws SchedulerException
deleteJob
in interface QuartzSchedulerMBean
SchedulerException
public java.lang.String[] getCalendarNames(java.lang.String instanceId) throws SchedulerException
getCalendarNames
in interface QuartzSchedulerMBean
SchedulerException
public javax.management.openmbean.CompositeData getJobDetail(java.lang.String instanceId, java.lang.String jobName, java.lang.String jobGroupName) throws SchedulerException
getJobDetail
in interface QuartzSchedulerMBean
SchedulerException
JobDetailSupport
public java.lang.String[] getJobGroupNames(java.lang.String instanceId) throws SchedulerException
getJobGroupNames
in interface QuartzSchedulerMBean
SchedulerException
public java.lang.String[] getJobNames(java.lang.String instanceId, java.lang.String groupName) throws SchedulerException
getJobNames
in interface QuartzSchedulerMBean
SchedulerException
public java.lang.String getJobStoreClassName()
getJobStoreClassName
in interface QuartzSchedulerMBean
public java.util.Set<java.lang.String> getPausedTriggerGroups(java.lang.String instanceId) throws SchedulerException
getPausedTriggerGroups
in interface QuartzSchedulerMBean
SchedulerException
public javax.management.openmbean.CompositeData getTrigger(java.lang.String instanceId, java.lang.String triggerName, java.lang.String triggerGroupName) throws SchedulerException
getTrigger
in interface QuartzSchedulerMBean
SchedulerException
public java.lang.String[] getTriggerGroupNames(java.lang.String instanceId) throws SchedulerException
getTriggerGroupNames
in interface QuartzSchedulerMBean
SchedulerException
public java.lang.String[] getTriggerNames(java.lang.String instanceId, java.lang.String triggerGroupName) throws SchedulerException
getTriggerNames
in interface QuartzSchedulerMBean
SchedulerException
public int getTriggerState(java.lang.String instanceId, java.lang.String triggerName, java.lang.String triggerGroupName) throws SchedulerException
getTriggerState
in interface QuartzSchedulerMBean
SchedulerException
public javax.management.openmbean.TabularData getTriggersOfJob(java.lang.String instanceId, java.lang.String jobName, java.lang.String jobGroupName) throws SchedulerException
getTriggersOfJob
in interface QuartzSchedulerMBean
SchedulerException
public boolean interruptJob(java.lang.String instanceId, java.lang.String jobName, java.lang.String jobGroupName) throws UnableToInterruptJobException
interruptJob
in interface QuartzSchedulerMBean
UnableToInterruptJobException
public java.util.Date scheduleJob(java.lang.String instanceId, java.lang.String jobName, java.lang.String jobGroup, java.lang.String triggerName, java.lang.String triggerGroup) throws SchedulerException
scheduleJob
in interface QuartzSchedulerMBean
SchedulerException
public boolean unscheduleJob(java.lang.String instanceId, java.lang.String triggerName, java.lang.String triggerGroup) throws SchedulerException
unscheduleJob
in interface QuartzSchedulerMBean
SchedulerException
public java.lang.String getVersion()
getVersion
in interface QuartzSchedulerMBean
public boolean isShutdown()
isShutdown
in interface QuartzSchedulerMBean
public boolean isStarted()
isStarted
in interface QuartzSchedulerMBean
public void start() throws SchedulerException
start
in interface QuartzSchedulerMBean
SchedulerException
public void shutdown()
shutdown
in interface QuartzSchedulerMBean
public void standby()
standby
in interface QuartzSchedulerMBean
public boolean isStandbyMode()
isStandbyMode
in interface QuartzSchedulerMBean
public java.lang.String getSchedulerName()
getSchedulerName
in interface QuartzSchedulerMBean
public java.lang.String getSchedulerInstanceId()
getSchedulerInstanceId
in interface QuartzSchedulerMBean
public java.lang.String getThreadPoolClassName()
getThreadPoolClassName
in interface QuartzSchedulerMBean
public int getThreadPoolSize()
getThreadPoolSize
in interface QuartzSchedulerMBean
public void pauseJob(java.lang.String instanceId, java.lang.String jobName, java.lang.String groupName) throws SchedulerException
pauseJob
in interface QuartzSchedulerMBean
SchedulerException
public void pauseJobGroup(java.lang.String instanceId, java.lang.String jobGroupName) throws SchedulerException
pauseJobGroup
in interface QuartzSchedulerMBean
SchedulerException
public void pauseAllTriggers(java.lang.String instanceId) throws SchedulerException
pauseAllTriggers
in interface QuartzSchedulerMBean
SchedulerException
public void pauseTriggerGroup(java.lang.String instanceId, java.lang.String groupName) throws SchedulerException
pauseTriggerGroup
in interface QuartzSchedulerMBean
SchedulerException
public void pauseTrigger(java.lang.String instanceId, java.lang.String triggerName, java.lang.String triggerGroup) throws SchedulerException
pauseTrigger
in interface QuartzSchedulerMBean
SchedulerException
public void resumeAllTriggers(java.lang.String instanceId) throws SchedulerException
resumeAllTriggers
in interface QuartzSchedulerMBean
SchedulerException
public void resumeJob(java.lang.String instanceId, java.lang.String jobName, java.lang.String jobGroupName) throws SchedulerException
resumeJob
in interface QuartzSchedulerMBean
SchedulerException
public void resumeJobGroup(java.lang.String instanceId, java.lang.String jobGroupName) throws SchedulerException
resumeJobGroup
in interface QuartzSchedulerMBean
SchedulerException
public void resumeTrigger(java.lang.String instanceId, java.lang.String triggerName, java.lang.String triggerGroupName) throws SchedulerException
resumeTrigger
in interface QuartzSchedulerMBean
SchedulerException
public void resumeTriggerGroup(java.lang.String instanceId, java.lang.String groupName) throws SchedulerException
resumeTriggerGroup
in interface QuartzSchedulerMBean
SchedulerException
public void triggerJobWithVolatileTrigger(java.lang.String instanceId, java.lang.String jobName, java.lang.String jobGroupName, java.util.Map<java.lang.String,java.lang.String> jobDataMap) throws SchedulerException
triggerJobWithVolatileTrigger
in interface QuartzSchedulerMBean
SchedulerException
public void triggerJob(java.lang.String instanceId, java.lang.String jobName, java.lang.String jobGroupName, java.util.Map<java.lang.String,java.lang.String> jobDataMap) throws SchedulerException
triggerJob
in interface QuartzSchedulerMBean
SchedulerException
public void jobAdded(JobDetail jobDetail)
SchedulerListener
Called by the
when a Scheduler
has been added.
JobDetail
jobAdded
in interface SchedulerListener
public void jobDeleted(java.lang.String jobName, java.lang.String groupName)
SchedulerListener
Called by the
when a Scheduler
has been deleted.
JobDetail
jobDeleted
in interface SchedulerListener
public void jobScheduled(Trigger trigger)
SchedulerListener
Called by the
when a Scheduler
is scheduled.
JobDetail
jobScheduled
in interface SchedulerListener
public void jobUnscheduled(java.lang.String triggerName, java.lang.String triggerGroup)
SchedulerListener
Called by the
when a Scheduler
is unscheduled.
JobDetail
jobUnscheduled
in interface SchedulerListener
public void jobsPaused(java.lang.String jobName, java.lang.String jobGroup)
SchedulerListener
Called by the
when a Scheduler
or group of JobDetail
has been
paused.
JobDetail
s
If a group was paused, then the jobName
parameter will be
null. If all jobs were paused, then both parameters will be null.
jobsPaused
in interface SchedulerListener
public void jobsResumed(java.lang.String jobName, java.lang.String jobGroup)
SchedulerListener
Called by the
when a Scheduler
or group of JobDetail
has been
un-paused.
JobDetail
s
If a group was resumed, then the jobName
parameter will
be null. If all jobs were paused, then both parameters will be null.
jobsResumed
in interface SchedulerListener
public void schedulerError(java.lang.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 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 process.
Scheduler
schedulerShuttingdown
in interface SchedulerListener
public void triggerFinalized(Trigger trigger)
SchedulerListener
Called by the
when a Scheduler
has reached the condition in which it will never fire again.
Trigger
triggerFinalized
in interface SchedulerListener
public void triggersPaused(java.lang.String triggerName, java.lang.String triggerGroup)
SchedulerListener
Called by the
when a Scheduler
or group of Trigger
has been paused.
Trigger
s
If a group was paused, then the triggerName
parameter
will be null.
triggersPaused
in interface SchedulerListener
public void triggersResumed(java.lang.String triggerName, java.lang.String triggerGroup)
SchedulerListener
Called by the
when a Scheduler
or group of Trigger
has been un-paused.
Trigger
s
If a group was resumed, then the triggerName
parameter
will be null.
triggersResumed
in interface SchedulerListener
public java.lang.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(java.lang.String eventType)
eventType
- public void sendNotification(java.lang.String eventType, java.lang.Object data)
eventType
- data
- public void sendNotification(java.lang.String eventType, java.lang.Object data, java.lang.String msg)
eventType
- data
- msg
- public void addNotificationListener(javax.management.NotificationListener notif, javax.management.NotificationFilter filter, java.lang.Object callBack)
addNotificationListener
in interface javax.management.NotificationBroadcaster
NotificationBroadcaster.addNotificationListener(javax.management.NotificationListener,
javax.management.NotificationFilter, java.lang.Object)
public javax.management.MBeanNotificationInfo[] getNotificationInfo()
getNotificationInfo
in interface javax.management.NotificationBroadcaster
NotificationBroadcaster.getNotificationInfo()
public void removeNotificationListener(javax.management.NotificationListener listener) throws javax.management.ListenerNotFoundException
removeNotificationListener
in interface javax.management.NotificationBroadcaster
javax.management.ListenerNotFoundException
NotificationBroadcaster.removeNotificationListener(javax.management.NotificationListener)
public void removeNotificationListener(javax.management.NotificationListener notif, javax.management.NotificationFilter filter, java.lang.Object callBack) throws javax.management.ListenerNotFoundException
removeNotificationListener
in interface javax.management.NotificationEmitter
javax.management.ListenerNotFoundException
NotificationEmitter.removeNotificationListener(javax.management.NotificationListener,
javax.management.NotificationFilter, java.lang.Object)
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 java.util.Map<java.lang.String,java.lang.Long> getPerformanceMetrics()
getPerformanceMetrics
in interface QuartzSchedulerMBean
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |