Package org.oddjob.scheduling

Class TimerBase

java.lang.Object

org.oddjob.framework.extend.BaseComponent

org.oddjob.framework.extend.BasePrimary

org.oddjob.scheduling.ScheduleBase

org.oddjob.scheduling.TimerBase

All Implemented Interfaces:

Serializable, Runnable, ArooaContextAware, ArooaSessionAware, Forceable, PropertyChangeNotifier, Iconic, LogEnabled, Resettable, Stateful, Stoppable, Structural

Direct Known Subclasses:

Retry, Timer

public abstract class TimerBase
extends ScheduleBase

Common functionality for Timers.

Author:

rob

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<Object,Object>	contextData	Provided to the schedule.

Fields inherited from class org.oddjob.scheduling.ScheduleBase

begun, childHelper, childStateReflector, stateHandler, stop

Constructor Summary

Constructors

Constructor	Description
TimerBase()

Method Summary

Modifier and Type	Method	Description
protected void	begin()	Sub classes must override this to submit the first execution.
protected void	CancelAndStopChild()	Cancel and child jobs that are submitted and stop any that are running.
protected boolean	changeStateLocked(TimerState required)
Clock	getClock()	Get the current clock.
ScheduleResult	getCurrent()	Get the current/next interval.
protected abstract StateCondition	getDefaultHaltOn()
protected abstract ResetAction	getDefaultReset()
StateCondition	getHaltOn()
Date	getLastDue()	Get the last due date.
protected abstract Interval	getLimits()	Implementation provided by sub classes so limits are available in scheduleFrom(Date).
Date	getNextDue()	Get the next due date.
ResetAction	getReset()
Schedule	getSchedule()
String	getTimeZone()	Get the time zone id to use in this schedule.
protected void	handleChildState(StateEvent event, StateListener listener)
protected boolean	internalSetNextDue(Date nextDue)	Set the next due date.
protected abstract boolean	isSkipMissedRuns()
protected void	onReset()	Override by subclasses to reset state.
protected void	onStop()	Subclasses can override to perform stopping operations.
protected void	postStop()	Subclasses can override to perform actions once children have stopped.
protected boolean	reschedule()	Reschedule a job.
protected void	reset(Resettable job)	Implementation provided by sub classes to decide what kind of reset to send to the child.
protected boolean	scheduleFrom(Date date)	Schedule a job from a given date.
void	setClock(Clock clock)	Set the clock.
void	setHaltOn(StateCondition haltOn)
void	setJob(Runnable job)
void	setNextDue(Date nextDue)	Manually set the Next Due Date.
void	setReschedule(Date reSchedule)
void	setReset(ResetAction reset)
void	setSchedule(Schedule schedule)	Set the schedule.
void	setScheduleExecutorService(ScheduledExecutorService scheduler)
void	setTimeZone(String timeZoneId)	Set the time zone.

Methods inherited from class org.oddjob.scheduling.ScheduleBase

addStructuralListener, fireDestroyedState, force, getStateChanger, getStateOp, hardReset, iconHelper, onDestroy, removeStructuralListener, run, softReset, stateHandler, stop

Methods inherited from class org.oddjob.framework.extend.BasePrimary

configure, getName, logger, logger, loggerName, save, setName, toString

Methods inherited from class org.oddjob.framework.extend.BaseComponent

addIconListener, addPropertyChangeListener, addStateListener, configure, destroy, firePropertyChange, getArooaSession, iconForId, initialise, lastStateEvent, onConfigured, onInitialised, removeIconListener, removePropertyChangeListener, removeStateListener, save, setArooaContext, setArooaSession

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.oddjob.Stateful

addStateListener, lastStateEvent, removeStateListener

Field Details

contextData

protected final Map<Object,Object> contextData

Provided to the schedule.

Constructor Details

TimerBase

public TimerBase()

Method Details

setScheduleExecutorService

@Inject
public void setScheduleExecutorService(ScheduledExecutorService scheduler)

begin

protected void begin()
              throws ComponentPersistException

Description copied from class: ScheduleBase

Sub classes must override this to submit the first execution.

Specified by:

begin in class ScheduleBase

Throws:

ComponentPersistException - If the scheduled time can't be saved.

onStop

protected void onStop()

Description copied from class: ScheduleBase

Subclasses can override to perform stopping operations.

Overrides:

onStop in class ScheduleBase

postStop

protected void postStop()

Description copied from class: ScheduleBase

Subclasses can override to perform actions once children have stopped.

Overrides:

postStop in class ScheduleBase

onReset

protected void onReset()

Description copied from class: ScheduleBase

Override by subclasses to reset state.

Overrides:

onReset in class ScheduleBase

getTimeZone

public String getTimeZone()

Get the time zone id to use in this schedule.

Returns:

The time zone id being used.

setTimeZone

public void setTimeZone(String timeZoneId)

Set the time zone.

Parameters:

timeZoneId - the timeZoneId.

setSchedule

public void setSchedule(Schedule schedule)

Set the schedule.

Parameters:

schedule - The schedule.

getSchedule

public Schedule getSchedule()

setReschedule

public void setReschedule(Date reSchedule)
                   throws OddjobLockedException

Throws:

OddjobLockedException

Reference Property:

reschedule

Description

Reschedule from the given date/time.

Required:

Only available once the timer has started.

CancelAndStopChild

protected void CancelAndStopChild()
                           throws FailedToStopException

Cancel and child jobs that are submitted and stop any that are running. This should only be run while locked because it temporarily sets the stop flag to fool the state listener into not rescheduling.

Throws:

FailedToStopException

scheduleFrom

protected boolean scheduleFrom(Date date)
                        throws ComponentPersistException

Schedule a job from a given date.

Parameters:

date - The date to schedule the job from.

Returns:

true if the job is scheduled again, false if it is not to be scheduled again.

Throws:

ComponentPersistException

getClock

public Clock getClock()

Get the current clock.

Returns:

The clock

setClock

public void setClock(Clock clock)

Set the clock. Only useful for testing.

Parameters:

clock - The clock.

setNextDue

public void setNextDue(Date nextDue)
                throws OddjobLockedException

Manually set the Next Due Date.

Parameters:

nextDue - The Next Due Date. May be null.

Throws:

OddjobLockedException

getNextDue

public Date getNextDue()

Get the next due date.

Returns:

The next due date

internalSetNextDue

protected boolean internalSetNextDue(Date nextDue)
                              throws ComponentPersistException

Set the next due date.

Parameters:

nextDue - The date schedule is next due. If null the job won't be scheduled and the child state reflector will be called to reflect the state of the child job.

Returns:

true if the job was scheduled. False it wasn't.

Throws:

ComponentPersistException

getCurrent

public ScheduleResult getCurrent()

Get the current/next interval.

Returns:

The interval, null if not due again.

getLastDue

public Date getLastDue()

Get the last due date.

Returns:

The last due date, null when a timer starts for the first time.

setJob

public void setJob(Runnable job)

Reference Property:

job

Description

The job to run when it's due.

Required:

Yes.

getLimits

protected abstract Interval getLimits()

Implementation provided by sub classes so limits are available in scheduleFrom(Date).

Returns:

The limits, or null. Retry has limits, timer doesn't.

reschedule

protected boolean reschedule()
                      throws ComponentPersistException

Reschedule a job.

Returns:

True if it was schedule, false if it wasn't.

Throws:

ComponentPersistException

reset

protected void reset(Resettable job)

Implementation provided by sub classes to decide what kind of reset to send to the child. Timer sends a hard reset, Retry sends a soft reset.

Parameters:

job - The child job that will be reset.

handleChildState

protected void handleChildState(StateEvent event,
 StateListener listener)
                         throws ComponentPersistException

Throws:

ComponentPersistException

changeStateLocked

protected boolean changeStateLocked(TimerState required)

getHaltOn

public StateCondition getHaltOn()

setHaltOn

public void setHaltOn(StateCondition haltOn)

getDefaultHaltOn

protected abstract StateCondition getDefaultHaltOn()

isSkipMissedRuns

protected abstract boolean isSkipMissedRuns()

getReset

public ResetAction getReset()

setReset

public void setReset(ResetAction reset)

getDefaultReset

protected abstract ResetAction getDefaultReset()