org.jboss.varia.scheduler
Class ScheduleManager

java.lang.Object
  org.jboss.mx.util.JBossNotificationBroadcasterSupport
      org.jboss.system.ServiceMBeanSupport
          org.jboss.varia.scheduler.ScheduleManager

All Implemented Interfaces:

javax.management.MBeanRegistration, javax.management.NotificationBroadcaster, javax.management.NotificationEmitter, org.jboss.system.Service, org.jboss.system.ServiceMBean, ScheduleManagerMBean

public class ScheduleManager
extends org.jboss.system.ServiceMBeanSupport
implements ScheduleManagerMBean

Schedule Manager which manage the Schedule and their matching Timer notifications and notification listeners. Each provider has to register when it is started where in turn their startProviding() method is called which allows him to add its Schedules because the Manager is now ready.

Version:

$Revision: 1.13.6.3 $

Author:

Andreas Schaefer

Nested Class Summary

class

ScheduleManager.MBeanListener This listener is waiting for its Timer Notification and call the appropriate method on the given Target (MBean) and count down the number of remaining repetitions.

Field Summary

static String

DEFAULT_TIMER_NAME Default Timer Object Name

Fields inherited from class org.jboss.system.ServiceMBeanSupport

log, server, SERVICE_CONTROLLER_SIG, serviceName

Fields inherited from interface org.jboss.varia.scheduler.ScheduleManagerMBean

OBJECT_NAME

Fields inherited from interface org.jboss.system.ServiceMBean

CREATE_EVENT, CREATED, DESTROY_EVENT, DESTROYED, FAILED, REGISTERED, START_EVENT, STARTED, STARTING, states, STOP_EVENT, STOPPED, STOPPING, UNREGISTERED

Constructor Summary

ScheduleManager()
Default (no-args) Constructor

Method Summary

int	addSchedule(javax.management.ObjectName pProvider, javax.management.ObjectName pTarget, String pMethodName, String[] pMethodSignature, Date pStartDate, long pPeriod, int pRepetitions) Adds a new Schedule to the Scheduler
protected void	destroyService() When Service is destroyed it will call the "unregisterProvider()" on all register Providers to let them remove their Schedules and being notified that they should stop providing.
javax.management.ObjectName	getObjectName(javax.management.MBeanServer pServer, javax.management.ObjectName pName)
String	getSchedules() Returns a list of the ids of all registered schedules
String	getTimerName()
boolean	isPaused()
boolean	isStartAtStartup()
boolean	isStarted()
void	registerProvider(String pProviderObjectName) Register a Provider to make him available.
void	removeSchedule(int pIdentification) Removes a Schedule so that no notification is sent anymore
void	restartSchedule() Stops the server right now and starts it right now.
void	setPaused(boolean pIsPaused) Pauses or restarts the Schedules which either suspends the notifications or start transfering them to the target
void	setStartAtStartup(boolean pStartAtStartup) Set the scheduler to start when MBean started or not.
void	setTimerName(String pTimerName) The JMX timer to use for the actual scheduling
void	startSchedules() Starts all the registered Schedules
protected void	startService() Creates the requested Timer if not already available and start all added Schedules.
void	stopSchedules(boolean pDoItNow) Stops all the registered Schedules
protected void	stopService() Stops all available Schedules.
void	unregisterProvider(String pProviderObjectName) Unregister a Provider which in turn calls "stopProviding()" indicating to the Provider to remove all the Schedules.

Methods inherited from class org.jboss.system.ServiceMBeanSupport

create, createService, destroy, getDeploymentInfo, getLog, getName, getNextNotificationSequenceNumber, getServer, getServiceName, getState, getStateString, jbossInternalCreate, jbossInternalDescription, jbossInternalDestroy, jbossInternalLifecycle, jbossInternalStart, jbossInternalStop, postDeregister, postRegister, preDeregister, preRegister, start, stop

Methods inherited from class org.jboss.mx.util.JBossNotificationBroadcasterSupport

addNotificationListener, getNotificationInfo, handleNotification, nextNotificationSequenceNumber, removeNotificationListener, removeNotificationListener, sendNotification

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.jboss.system.ServiceMBean

getName, getState, getStateString, jbossInternalLifecycle

Methods inherited from interface org.jboss.system.Service

create, destroy, start, stop

Field Detail

DEFAULT_TIMER_NAME

public static String DEFAULT_TIMER_NAME

Default Timer Object Name

Constructor Detail

ScheduleManager

public ScheduleManager()

Default (no-args) Constructor

Method Detail

startSchedules

public void startSchedules()

Starts all the registered Schedules

Specified by:

startSchedules in interface ScheduleManagerMBean

stopSchedules

public void stopSchedules(boolean pDoItNow)

Stops all the registered Schedules

Specified by:

stopSchedules in interface ScheduleManagerMBean

Parameters:

pDoItNow - If true the schedule will be stopped without waiting for the next scheduled call otherwise the next call will be performed before the schedule is stopped.

restartSchedule

public void restartSchedule()

Stops the server right now and starts it right now.

Specified by:

restartSchedule in interface ScheduleManagerMBean

registerProvider

public void registerProvider(String pProviderObjectName)

Register a Provider to make him available. In turn this method calls "startProviding()" method on the Provider to indicate that the Provider can start adding Schedules.

Specified by:

registerProvider in interface ScheduleManagerMBean

Parameters:

pProviderObjectName - Object Name of the Provider

unregisterProvider

public void unregisterProvider(String pProviderObjectName)

Unregister a Provider which in turn calls "stopProviding()" indicating to the Provider to remove all the Schedules.

Specified by:

unregisterProvider in interface ScheduleManagerMBean

Parameters:

pProviderObjectName - Object Name of the Provider

addSchedule

public int addSchedule(javax.management.ObjectName pProvider,
                       javax.management.ObjectName pTarget,
                       String pMethodName,
                       String[] pMethodSignature,
                       Date pStartDate,
                       long pPeriod,
                       int pRepetitions)

Adds a new Schedule to the Scheduler

Specified by:

addSchedule in interface ScheduleManagerMBean

Parameters:

pTarget - Object Name of the Target MBean

pMethodName - Name of the method to be called

pMethodSignature - List of Attributes of the method to be called where ...

pStartDate - Date when the schedule is started

pRepetitions - Initial Number of repetitions

Returns:

Identification of the Schedule used later to remove it if necessary

removeSchedule

public void removeSchedule(int pIdentification)

Removes a Schedule so that no notification is sent anymore

Specified by:

removeSchedule in interface ScheduleManagerMBean

Parameters:

pIdentification - Identification returned by addSchedule() or getSchedules().

getSchedules

public String getSchedules()

Returns a list of the ids of all registered schedules

Returns:

List of Ids separated by a ","

isPaused

public boolean isPaused()

Returns:

True if all the Schedules are paused meaning that even when the notifications are sent to the listener they are ignored. ATTENTION: this applies to all registered Schedules and any notifications are lost during pausing

setPaused

public void setPaused(boolean pIsPaused)

Pauses or restarts the Schedules which either suspends the notifications or start transfering them to the target

Parameters:

pIsPaused - True when the Schedules are paused or false when they resume

isStarted

public boolean isStarted()

Returns:

true if the Schedule Manager is started

isStartAtStartup

public boolean isStartAtStartup()

Specified by:

isStartAtStartup in interface ScheduleManagerMBean

Returns:

true if the scheduler should be started upon MBean start or not

setStartAtStartup

public void setStartAtStartup(boolean pStartAtStartup)

Set the scheduler to start when MBean started or not. Note that this method only affects when the startService() gets called (normally at startup time.

Specified by:

setStartAtStartup in interface ScheduleManagerMBean

Parameters:

pStartAtStartup - if the scheduler should be started upon MBean start or not

getTimerName

public String getTimerName()

Specified by:

getTimerName in interface ScheduleManagerMBean

Returns:

Name of the Timer MBean used in here

setTimerName

public void setTimerName(String pTimerName)

Description copied from interface: ScheduleManagerMBean

The JMX timer to use for the actual scheduling

Specified by:

setTimerName in interface ScheduleManagerMBean

Parameters:

pTimerName - Object Name of the Timer MBean to be used. If null or not a valid ObjectName the default will be used

getObjectName

public javax.management.ObjectName getObjectName(javax.management.MBeanServer pServer,
                                                 javax.management.ObjectName pName)
                                          throws javax.management.MalformedObjectNameException

Overrides:

getObjectName in class org.jboss.system.ServiceMBeanSupport

Throws:

javax.management.MalformedObjectNameException

startService

protected void startService()
                     throws Exception

Creates the requested Timer if not already available and start all added Schedules. ATTENTION: the start of the schedules is not necessary when the service is started but this method is also called when the service is restarted and therefore schedules can be available.

Overrides:

startService in class org.jboss.system.ServiceMBeanSupport

Throws:

Exception

stopService

protected void stopService()

Stops all available Schedules.

Overrides:

stopService in class org.jboss.system.ServiceMBeanSupport

destroyService

protected void destroyService()

When Service is destroyed it will call the "unregisterProvider()" on all register Providers to let them remove their Schedules and being notified that they should stop providing.

Overrides:

destroyService in class org.jboss.system.ServiceMBeanSupport