com.espertech.esper.pattern.observer
Class TimerIntervalObserver

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

All Implemented Interfaces:

EventObserver, ScheduleHandleCallback

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

Observer that will wait a certain interval before indicating true (raising an event).

Constructor Summary

TimerIntervalObserver(long msec, MatchedEventMap beginState, ObserverEventEvaluator observerEventEvaluator)
Ctor.

Method Summary

void	accept(EventObserverVisitor visitor)
MatchedEventMap	getBeginState()
void	scheduledTrigger(EngineLevelExtensionServicesContext engineLevelExtensionServicesContext) 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

Constructor Detail

TimerIntervalObserver

public TimerIntervalObserver(long msec,
                             MatchedEventMap beginState,
                             ObserverEventEvaluator observerEventEvaluator)

Ctor.

Parameters:

msec - - number of milliseconds

beginState - - start state

observerEventEvaluator - - receiver for events

Method Detail

scheduledTrigger

public final void scheduledTrigger(EngineLevelExtensionServicesContext engineLevelExtensionServicesContext)

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:

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

getBeginState

public MatchedEventMap getBeginState()

Specified by:

getBeginState in interface EventObserver

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