Package 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 Details

    • EPTYPE

      public static final EPTypeClass EPTYPE

    • scheduleCallbackId

      protected int scheduleCallbackId

    • deltaCompute

      protected PatternDeltaCompute deltaCompute

  • Constructor Details

    • TimerIntervalObserverFactory

      public TimerIntervalObserverFactory()

  • Method Details

    • 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