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

Class TimerScheduleObserverFactory

java.lang.Object

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

All Implemented Interfaces:

ObserverFactory

public class TimerScheduleObserverFactory
extends Object
implements ObserverFactory

Factory for ISO8601 repeating interval observers that indicate truth when a time point was reached.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	scheduleCallbackId

Constructor Summary

Constructors

Constructor and Description
TimerScheduleObserverFactory()

Method Summary

Modifier and Type	Method and Description
TimerScheduleSpec	computeSpecDynamic(MatchedEventMap beginState, PatternAgentInstanceContext context)
boolean	isNonRestarting()
EventObserver	makeObserver(PatternAgentInstanceContext context, MatchedEventMap beginState, ObserverEventEvaluator observerEventEvaluator, Object observerState, boolean isFilterChildNonQuitting) Make an observer instance.
void	setAllConstant(boolean allConstant)
void	setOptionalConvertor(MatchedEventConvertor optionalConvertor)
void	setScheduleCallbackId(int scheduleCallbackId)
void	setScheduleComputer(com.espertech.esper.common.internal.epl.pattern.observer.TimerScheduleSpecCompute scheduleComputer)

Methods inherited from class java.lang.Object

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

Field Detail

scheduleCallbackId

protected int scheduleCallbackId

Constructor Detail

TimerScheduleObserverFactory

public TimerScheduleObserverFactory()

Method Detail

setAllConstant

public void setAllConstant(boolean allConstant)

setScheduleComputer

public void setScheduleComputer(com.espertech.esper.common.internal.epl.pattern.observer.TimerScheduleSpecCompute scheduleComputer)

setOptionalConvertor

public void setOptionalConvertor(MatchedEventConvertor optionalConvertor)

setScheduleCallbackId

public void setScheduleCallbackId(int scheduleCallbackId)

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

computeSpecDynamic

public TimerScheduleSpec computeSpecDynamic(MatchedEventMap beginState,
                                            PatternAgentInstanceContext context)