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

Class TimerIntervalObserverFactory

java.lang.Object

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

All Implemented Interfaces:

ObserverFactory

public class TimerIntervalObserverFactory
extends Object
implements ObserverFactory

Factory for making observer instances.

Field Summary

Fields

Modifier and Type	Field and Description
protected PatternDeltaCompute	deltaCompute
static EPTypeClass	EPTYPE
protected int	scheduleCallbackId

Constructor Summary

Constructors

Constructor and Description
TimerIntervalObserverFactory()

Method Summary

Modifier and Type	Method and Description
PatternDeltaCompute	getDeltaCompute()
int	getScheduleCallbackId()
boolean	isNonRestarting()
EventObserver	makeObserver(PatternAgentInstanceContext context, MatchedEventMap beginState, ObserverEventEvaluator observerEventEvaluator, Object observerState, boolean isFilterChildNonQuitting) Make an observer instance.
void	setDeltaCompute(PatternDeltaCompute deltaCompute)
void	setScheduleCallbackId(int scheduleCallbackId)

Methods inherited from class java.lang.Object

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

Field Detail

EPTYPE

public static final EPTypeClass EPTYPE

scheduleCallbackId

protected int scheduleCallbackId

deltaCompute

protected PatternDeltaCompute deltaCompute

Constructor Detail

TimerIntervalObserverFactory

public TimerIntervalObserverFactory()

Method Detail

setScheduleCallbackId

public void setScheduleCallbackId(int scheduleCallbackId)

setDeltaCompute

public void setDeltaCompute(PatternDeltaCompute deltaCompute)

getDeltaCompute

public PatternDeltaCompute getDeltaCompute()

getScheduleCallbackId

public int getScheduleCallbackId()

makeObserver

public EventObserver makeObserver(PatternAgentInstanceContext context,
                                  MatchedEventMap beginState,
                                  ObserverEventEvaluator observerEventEvaluator,
                                  Object observerState,
                                  boolean isFilterChildNonQuitting)

Description copied from interface: ObserverFactory

Make an observer instance.

Specified by:

makeObserver in interface ObserverFactory

Parameters:

context - - services that may be required by observer implementation

beginState - - start state for observer

observerEventEvaluator - - receiver for events observed

observerState - - state node for observer

isFilterChildNonQuitting - true for non-quitting filter

Returns:

observer instance

isNonRestarting

public boolean isNonRestarting()

Specified by:

isNonRestarting in interface ObserverFactory