kieker.analysis.stage

Class DynamicEventDispatcher

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<java.lang.Object>

kieker.analysis.stage.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 and 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 and 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 Detail

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 Detail

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)