Package kieker.analysis.generic

Class DynamicEventDispatcher

java.lang.Object
teetime.framework.AbstractStage
teetime.framework.AbstractConsumerStage<java.lang.Object>
kieker.analysis.generic.DynamicEventDispatcher
public class DynamicEventDispatcher
extends teetime.framework.AbstractConsumerStage<java.lang.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 java.lang.Object> rootEventMatcher, boolean countEvents, boolean reportUnknown, boolean outputOther)
    Create a new dynamic dispatcher.

  • Method Summary

    Modifier and Type Method Description
    protected void execute​(java.lang.Object event)  
    long getEventCount()  
    teetime.framework.OutputPort<java.lang.Object> getOutputOtherPort()  
    void onTerminating()  
    void registerOutput​(IEventMatcher<? extends java.lang.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 java.lang.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​(java.lang.Object event) throws java.lang.Exception
      Specified by:
      execute in class teetime.framework.AbstractConsumerStage<java.lang.Object>
      Throws:
      java.lang.Exception

    • getOutputOtherPort

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

    • getEventCount

      public long getEventCount()

    • onTerminating

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

    • registerOutput

      public void registerOutput​(IEventMatcher<? extends java.lang.Object> leaveEventMatcher)