Package kieker.analysis.generic

Class DynamicEventDispatcher

java.lang.Object
teetime.framework.AbstractStage
teetime.framework.AbstractConsumerStage<Object>
kieker.analysis.generic.DynamicEventDispatcher
public class DynamicEventDispatcher extends teetime.framework.AbstractConsumerStage<Object>
The DynamicEventDispatcher allows to select specific events from the event stream and send them to a specific event stream.
Since:
1.15
Author:
Reiner Jung

  • Field Summary

    Fields inherited from class teetime.framework.AbstractConsumerStage

    inputPort

    Fields inherited from class teetime.framework.AbstractStage

    logger

  • Constructor Summary

    Constructors
    Constructor
    Description
    DynamicEventDispatcher(IEventMatcher<? extends Object> rootEventMatcher, boolean countEvents, boolean reportUnknown, boolean outputOther)
    Create a new dynamic dispatcher.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    execute(Object event)
     
    long
    getEventCount()
     
    teetime.framework.OutputPort<Object>
    getOutputOtherPort()
     
    void
    onTerminating()
     
    void
    registerOutput(IEventMatcher<? extends Object> leaveEventMatcher)
     

    Methods inherited from class teetime.framework.AbstractConsumerStage

    createInputPort, execute, getInputPort

    Methods inherited from class teetime.framework.AbstractStage

    abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • DynamicEventDispatcher

      public DynamicEventDispatcher(IEventMatcher<? extends Object> rootEventMatcher, boolean countEvents, boolean reportUnknown, boolean outputOther)
      Create a new dynamic dispatcher.
      Parameters:
      rootEventMatcher - first matcher in a sequence of matchers used for this dispatcher
      countEvents - flag to activate event counting
      reportUnknown - report on unknown event types
      outputOther - provide an output port for events not send to other ports

  • Method Details

    • execute

      protected void execute(Object event) throws Exception
      Specified by:
      execute in class teetime.framework.AbstractConsumerStage<Object>
      Throws:
      Exception

    • getOutputOtherPort

      public teetime.framework.OutputPort<Object> getOutputOtherPort()

    • getEventCount

      public long getEventCount()

    • onTerminating

      public void onTerminating()
      Overrides:
      onTerminating in class teetime.framework.AbstractStage

    • registerOutput

      public void registerOutput(IEventMatcher<? extends Object> leaveEventMatcher)