com.espertech.esper.pattern.observer
Class TimerScheduleObserver

java.lang.Object
  com.espertech.esper.pattern.observer.TimerScheduleObserver

All Implemented Interfaces:

EventObserver, ScheduleHandleCallback

public class TimerScheduleObserver
extends java.lang.Object
implements EventObserver, ScheduleHandleCallback

Observer implementation for indicating that a certain time arrived, similar to "crontab".

Field Summary

protected java.util.Calendar	anchorTime
protected MatchedEventMap	beginState
protected boolean	isTimerActive
protected ObserverEventEvaluator	observerEventEvaluator
protected EPStatementHandleCallback	scheduleHandle
protected ScheduleSlot	scheduleSlot

Constructor Summary

TimerScheduleObserver(TimerScheduleSpec spec, MatchedEventMap beginState, ObserverEventEvaluator observerEventEvaluator, boolean isFilterChildNonQuitting)
Ctor.

Method Summary

void	accept(EventObserverVisitor visitor)
MatchedEventMap	getBeginState()
void	scheduledTrigger(ExtensionServicesContext extensionServicesContext) Callback that is invoked as indicated by a schedule added to the scheduling service.
void	startObserve() Start observing.
void	stopObserve() Stop observing.

Methods inherited from class java.lang.Object

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

Field Detail

scheduleSlot

protected final ScheduleSlot scheduleSlot

beginState

protected MatchedEventMap beginState

observerEventEvaluator

protected final ObserverEventEvaluator observerEventEvaluator

anchorTime

protected java.util.Calendar anchorTime

isTimerActive

protected boolean isTimerActive

scheduleHandle

protected EPStatementHandleCallback scheduleHandle

Constructor Detail

TimerScheduleObserver

public TimerScheduleObserver(TimerScheduleSpec spec,
                             MatchedEventMap beginState,
                             ObserverEventEvaluator observerEventEvaluator,
                             boolean isFilterChildNonQuitting)

Ctor.

Parameters:

beginState - - start state

observerEventEvaluator - - receiver for events

Method Detail

getBeginState

public MatchedEventMap getBeginState()

Specified by:

getBeginState in interface EventObserver

scheduledTrigger

public final void scheduledTrigger(ExtensionServicesContext extensionServicesContext)

Description copied from interface: ScheduleHandleCallback

Callback that is invoked as indicated by a schedule added to the scheduling service.

Specified by:

scheduledTrigger in interface ScheduleHandleCallback

Parameters:

extensionServicesContext - is a marker interface for providing custom extension services passed to the triggered class

startObserve

public void startObserve()

Description copied from interface: EventObserver

Start observing.

Specified by:

startObserve in interface EventObserver

stopObserve

public void stopObserve()

Description copied from interface: EventObserver

Stop observing.

Specified by:

stopObserve in interface EventObserver

accept

public void accept(EventObserverVisitor visitor)

Specified by:

accept in interface EventObserver