public class TypeFilter
extends teetime.framework.AbstractConsumerStage<java.lang.Object>
Constructor and Description |
---|
TypeFilter(java.lang.Class<?>[] acceptedClasses)
Creates a new instance of this class using the given parameters.
|
Modifier and Type | Method and Description |
---|---|
protected void |
execute(java.lang.Object event)
This method represents the input port for the incoming objects.
|
teetime.framework.OutputPort<java.lang.Object> |
getMatchingTypeOutputPort()
Returns the output port where the incoming matching objects will be sent to.
|
teetime.framework.OutputPort<java.lang.Object> |
getMismatchingTypeOutputPort()
Returns the output port where the incoming objects will be sent to, which do not match the configured types.
|
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, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted
public TypeFilter(java.lang.Class<?>[] acceptedClasses)
acceptedClasses
- The types which will be accepted by the filter.protected void execute(java.lang.Object event)
execute
in class teetime.framework.AbstractConsumerStage<java.lang.Object>
event
- The new incoming object.public teetime.framework.OutputPort<java.lang.Object> getMatchingTypeOutputPort()
public teetime.framework.OutputPort<java.lang.Object> getMismatchingTypeOutputPort()
Copyright 2020 Kieker Project, http://kieker-monitoring.net