Package com.espertech.esper.common.internal.epl.pattern.observer

Class TimerAtObserver

java.lang.Object

com.espertech.esper.common.internal.epl.pattern.observer.TimerAtObserver

All Implemented Interfaces:

EventObserver, ScheduleHandleCallback

public class TimerAtObserver
extends Object
implements EventObserver, ScheduleHandleCallback

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

Field Summary

Fields

Modifier and Type	Field	Description
static final String	NAME_AUDITPROVIDER_SCHEDULE

Constructor Summary

Constructors

Constructor	Description
TimerAtObserver(ScheduleSpec scheduleSpec, MatchedEventMap beginState, ObserverEventEvaluator observerEventEvaluator)	Ctor.

Method Summary

Modifier and Type	Method	Description
void	accept(EventObserverVisitor visitor)
MatchedEventMap	getBeginState()
final void	scheduledTrigger()	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 Details

NAME_AUDITPROVIDER_SCHEDULE

public static final String NAME_AUDITPROVIDER_SCHEDULE

See Also:

• Constant Field Values

Constructor Details

TimerAtObserver

public TimerAtObserver(ScheduleSpec scheduleSpec,
 MatchedEventMap beginState,
 ObserverEventEvaluator observerEventEvaluator)

Ctor.

Parameters:

scheduleSpec - - specification containing the crontab schedule

beginState - - start state

observerEventEvaluator - - receiver for events

Method Details

getBeginState

public MatchedEventMap getBeginState()

Specified by:

getBeginState in interface EventObserver

scheduledTrigger

public final void scheduledTrigger()

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

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