|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectjavax.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 QuartzSchedulerMBeanSchedulerException
public javax.management.openmbean.TabularData getAllJobDetails(java.lang.String instanceId)
throws SchedulerException
getAllJobDetails in interface QuartzSchedulerMBeanSchedulerExceptionJobDetailSupport
public javax.management.openmbean.TabularData getAllTriggers(java.lang.String instanceId)
throws SchedulerException
getAllTriggers in interface QuartzSchedulerMBeanSchedulerExceptionTriggerSupport
public void addJob(java.lang.String instanceId,
javax.management.openmbean.CompositeData jobDetail,
boolean replace)
throws SchedulerException
addJob in interface QuartzSchedulerMBeanSchedulerException
public void deleteCalendar(java.lang.String instanceId,
java.lang.String name)
throws SchedulerException
deleteCalendar in interface QuartzSchedulerMBeanSchedulerException
public boolean deleteJob(java.lang.String instanceId,
java.lang.String jobName,
java.lang.String jobGroupName)
throws SchedulerException
deleteJob in interface QuartzSchedulerMBeanSchedulerException
public java.lang.String[] getCalendarNames(java.lang.String instanceId)
throws SchedulerException
getCalendarNames in interface QuartzSchedulerMBeanSchedulerException
public javax.management.openmbean.CompositeData getJobDetail(java.lang.String instanceId,
java.lang.String jobName,
java.lang.String jobGroupName)
throws SchedulerException
getJobDetail in interface QuartzSchedulerMBeanSchedulerExceptionJobDetailSupport
public java.lang.String[] getJobGroupNames(java.lang.String instanceId)
throws SchedulerException
getJobGroupNames in interface QuartzSchedulerMBeanSchedulerException
public java.lang.String[] getJobNames(java.lang.String instanceId,
java.lang.String groupName)
throws SchedulerException
getJobNames in interface QuartzSchedulerMBeanSchedulerExceptionpublic 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 QuartzSchedulerMBeanSchedulerException
public javax.management.openmbean.CompositeData getTrigger(java.lang.String instanceId,
java.lang.String triggerName,
java.lang.String triggerGroupName)
throws SchedulerException
getTrigger in interface QuartzSchedulerMBeanSchedulerException
public java.lang.String[] getTriggerGroupNames(java.lang.String instanceId)
throws SchedulerException
getTriggerGroupNames in interface QuartzSchedulerMBeanSchedulerException
public java.lang.String[] getTriggerNames(java.lang.String instanceId,
java.lang.String triggerGroupName)
throws SchedulerException
getTriggerNames in interface QuartzSchedulerMBeanSchedulerException
public int getTriggerState(java.lang.String instanceId,
java.lang.String triggerName,
java.lang.String triggerGroupName)
throws SchedulerException
getTriggerState in interface QuartzSchedulerMBeanSchedulerException
public javax.management.openmbean.TabularData getTriggersOfJob(java.lang.String instanceId,
java.lang.String jobName,
java.lang.String jobGroupName)
throws SchedulerException
getTriggersOfJob in interface QuartzSchedulerMBeanSchedulerException
public boolean interruptJob(java.lang.String instanceId,
java.lang.String jobName,
java.lang.String jobGroupName)
throws UnableToInterruptJobException
interruptJob in interface QuartzSchedulerMBeanUnableToInterruptJobException
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 QuartzSchedulerMBeanSchedulerException
public boolean unscheduleJob(java.lang.String instanceId,
java.lang.String triggerName,
java.lang.String triggerGroup)
throws SchedulerException
unscheduleJob in interface QuartzSchedulerMBeanSchedulerExceptionpublic java.lang.String getVersion()
getVersion in interface QuartzSchedulerMBeanpublic boolean isShutdown()
isShutdown in interface QuartzSchedulerMBeanpublic boolean isStarted()
isStarted in interface QuartzSchedulerMBean
public void start()
throws SchedulerException
start in interface QuartzSchedulerMBeanSchedulerExceptionpublic void shutdown()
shutdown in interface QuartzSchedulerMBeanpublic void standby()
standby in interface QuartzSchedulerMBeanpublic boolean isStandbyMode()
isStandbyMode in interface QuartzSchedulerMBeanpublic java.lang.String getSchedulerName()
getSchedulerName in interface QuartzSchedulerMBeanpublic java.lang.String getSchedulerInstanceId()
getSchedulerInstanceId in interface QuartzSchedulerMBeanpublic java.lang.String getThreadPoolClassName()
getThreadPoolClassName in interface QuartzSchedulerMBeanpublic 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 QuartzSchedulerMBeanSchedulerException
public void pauseJobGroup(java.lang.String instanceId,
java.lang.String jobGroupName)
throws SchedulerException
pauseJobGroup in interface QuartzSchedulerMBeanSchedulerException
public void pauseAllTriggers(java.lang.String instanceId)
throws SchedulerException
pauseAllTriggers in interface QuartzSchedulerMBeanSchedulerException
public void pauseTriggerGroup(java.lang.String instanceId,
java.lang.String groupName)
throws SchedulerException
pauseTriggerGroup in interface QuartzSchedulerMBeanSchedulerException
public void pauseTrigger(java.lang.String instanceId,
java.lang.String triggerName,
java.lang.String triggerGroup)
throws SchedulerException
pauseTrigger in interface QuartzSchedulerMBeanSchedulerException
public void resumeAllTriggers(java.lang.String instanceId)
throws SchedulerException
resumeAllTriggers in interface QuartzSchedulerMBeanSchedulerException
public void resumeJob(java.lang.String instanceId,
java.lang.String jobName,
java.lang.String jobGroupName)
throws SchedulerException
resumeJob in interface QuartzSchedulerMBeanSchedulerException
public void resumeJobGroup(java.lang.String instanceId,
java.lang.String jobGroupName)
throws SchedulerException
resumeJobGroup in interface QuartzSchedulerMBeanSchedulerException
public void resumeTrigger(java.lang.String instanceId,
java.lang.String triggerName,
java.lang.String triggerGroupName)
throws SchedulerException
resumeTrigger in interface QuartzSchedulerMBeanSchedulerException
public void resumeTriggerGroup(java.lang.String instanceId,
java.lang.String groupName)
throws SchedulerException
resumeTriggerGroup in interface QuartzSchedulerMBeanSchedulerException
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 QuartzSchedulerMBeanSchedulerException
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 QuartzSchedulerMBeanSchedulerExceptionpublic 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 SchedulerListenerpublic 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.
JobDetails
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.
JobDetails
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 SchedulerJobStore,
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 SchedulerListenerpublic void schedulerStarted()
SchedulerListener
Called by the to inform the listener
that it has started.
Scheduler
schedulerStarted in interface SchedulerListenerpublic void schedulerInStandbyMode()
SchedulerListener
Called by the to inform the listener
that it has move to standby mode.
Scheduler
schedulerInStandbyMode in interface SchedulerListenerpublic void schedulerShutdown()
SchedulerListener
Called by the to inform the listener
that it has shutdown.
Scheduler
schedulerShutdown in interface SchedulerListenerpublic void schedulerShuttingdown()
SchedulerListener
Called by the to inform the listener
that it has begun the shutdown process.
Scheduler
schedulerShuttingdown in interface SchedulerListenerpublic 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.
Triggers
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.
Triggers
If a group was resumed, then the triggerName parameter
will be null.
triggersResumed in interface SchedulerListenerpublic java.lang.String getName()
JobListener
Get the name of the JobListener.
getName in interface JobListenerpublic 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 JobListenerJobListener.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 JobListenerJobListener.jobExecutionVetoed(JobExecutionContext)
public void jobWasExecuted(JobExecutionContext context,
JobExecutionException jobException)
JobListener
Called by the after a Scheduler
has been executed, and be for the associated JobDetailTrigger's
triggered(xx) method has been called.
jobWasExecuted in interface JobListenerpublic 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.NotificationBroadcasterNotificationBroadcaster.addNotificationListener(javax.management.NotificationListener,
javax.management.NotificationFilter, java.lang.Object)public javax.management.MBeanNotificationInfo[] getNotificationInfo()
getNotificationInfo in interface javax.management.NotificationBroadcasterNotificationBroadcaster.getNotificationInfo()
public void removeNotificationListener(javax.management.NotificationListener listener)
throws javax.management.ListenerNotFoundException
removeNotificationListener in interface javax.management.NotificationBroadcasterjavax.management.ListenerNotFoundExceptionNotificationBroadcaster.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.NotificationEmitterjavax.management.ListenerNotFoundExceptionNotificationEmitter.removeNotificationListener(javax.management.NotificationListener,
javax.management.NotificationFilter, java.lang.Object)public boolean isSampledStatisticsEnabled()
isSampledStatisticsEnabled in interface QuartzSchedulerMBeanpublic void setSampledStatisticsEnabled(boolean enabled)
setSampledStatisticsEnabled in interface QuartzSchedulerMBeanpublic long getJobsCompletedMostRecentSample()
getJobsCompletedMostRecentSample in interface QuartzSchedulerMBeanpublic long getJobsExecutedMostRecentSample()
getJobsExecutedMostRecentSample in interface QuartzSchedulerMBeanpublic long getJobsScheduledMostRecentSample()
getJobsScheduledMostRecentSample in interface QuartzSchedulerMBeanpublic 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 | |||||||||