Class TimerWithinOrMaxCountGuard

java.lang.Object
com.espertech.esper.common.internal.epl.pattern.guard.TimerWithinOrMaxCountGuard
All Implemented Interfaces:
Guard, ScheduleHandleCallback

public class TimerWithinOrMaxCountGuard extends Object implements Guard, ScheduleHandleCallback
Guard implementation that keeps a timer instance and quits when the timer expired, and also keeps a count of the number of matches so far, checking both count and timer, letting all MatchedEventMap instances pass until then.
  • Field Details

  • Constructor Details

    • TimerWithinOrMaxCountGuard

      public TimerWithinOrMaxCountGuard(long deltaTime, int numCountTo, Quitable quitable)
      Ctor.
      Parameters:
      deltaTime - - number of millisecond to guard expiration
      numCountTo - - max number of counts
      quitable - - to use to indicate that the gaurd quitted
  • Method Details

    • startGuard

      public void startGuard()
      Description copied from interface: Guard
      Start the guard operation.
      Specified by:
      startGuard in interface Guard
    • inspect

      public boolean inspect(MatchedEventMap matchEvent)
      Description copied from interface: Guard
      Returns true if inspection shows that the match events can pass, or false to not pass.
      Specified by:
      inspect in interface Guard
      Parameters:
      matchEvent - is the map of matching events
      Returns:
      true to pass, false to not pass
    • stopGuard

      public void stopGuard()
      Description copied from interface: Guard
      Called when sub-expression quits, or when the pattern stopped.
      Specified by:
      stopGuard in interface Guard
    • scheduledTrigger

      public 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
    • accept

      public void accept(EventGuardVisitor visitor)
      Specified by:
      accept in interface Guard