public class DynamicEventDispatcher
extends teetime.framework.AbstractConsumerStage<java.lang.Object>
Constructor and Description |
---|
DynamicEventDispatcher(IEventMatcher<? extends java.lang.Object> rootEventMatcher,
boolean countEvents,
boolean reportUnknown,
boolean outputOther)
Create a new dynamic dispatcher.
|
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) |
createInputPort, execute, getInputPort
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
public DynamicEventDispatcher(IEventMatcher<? extends java.lang.Object> rootEventMatcher, boolean countEvents, boolean reportUnknown, boolean outputOther)
rootEventMatcher
- first matcher in a sequence of matchers used for this dispatchercountEvents
- flag to activate event countingreportUnknown
- report on unknown event typesoutputOther
- provide an output port for events not send to other portsprotected void execute(java.lang.Object event) throws java.lang.Exception
execute
in class teetime.framework.AbstractConsumerStage<java.lang.Object>
java.lang.Exception
public teetime.framework.OutputPort<java.lang.Object> getOutputOtherPort()
public long getEventCount()
public void onTerminating()
onTerminating
in class teetime.framework.AbstractStage
public void registerOutput(IEventMatcher<? extends java.lang.Object> leaveEventMatcher)
Copyright 2021 Kieker Project, http://kieker-monitoring.net