T
- Type parameter for specific record types.public abstract class AbstractTraceIdFilter<T>
extends teetime.framework.AbstractConsumerStage<T>
TraceIdFilterOld
. Each concrete component filters the trace ids of a specific record type T.Constructor and Description |
---|
AbstractTraceIdFilter(boolean acceptAllTraces,
java.util.Set<java.lang.Long> selectedTraceIds)
Creates a new instance of this class using the given parameters.
|
Modifier and Type | Method and Description |
---|---|
protected void |
execute(T record) |
teetime.framework.OutputPort<T> |
getMatchingTraceIdOutputPort()
Returns the output port delivering the records with matching IDs.
|
teetime.framework.OutputPort<T> |
getMismatchingTraceIdOutputPort()
Returns the output port delivering the records with the non matching IDs.
|
protected abstract long |
getRecordsTraceId(T record) |
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 AbstractTraceIdFilter(boolean acceptAllTraces, java.util.Set<java.lang.Long> selectedTraceIds)
acceptAllTraces
- Determining whether to accept all traces, regardless of the given trace IDs.selectedTraceIds
- Determining which trace IDs should be accepted by this filter.protected void execute(T record)
execute
in class teetime.framework.AbstractConsumerStage<T>
protected abstract long getRecordsTraceId(T record)
public teetime.framework.OutputPort<T> getMatchingTraceIdOutputPort()
public teetime.framework.OutputPort<T> getMismatchingTraceIdOutputPort()
Copyright 2021 Kieker Project, http://kieker-monitoring.net