public class TraceIdFilter extends teetime.framework.AbstractConsumerStage<IMonitoringRecord>
Constructor and Description |
---|
TraceIdFilter(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(IMonitoringRecord element) |
teetime.framework.OutputPort<IMonitoringRecord> |
getMatchingTraceIdOutputPort()
Returns the output port delivering the records with matching IDs.
|
teetime.framework.OutputPort<IMonitoringRecord> |
getMismatchingTraceIdOutputPort()
Returns the output port delivering the records with the non matching IDs.
|
protected void |
onTerminating() |
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 TraceIdFilter(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 onTerminating()
onTerminating
in class teetime.framework.AbstractStage
protected void execute(IMonitoringRecord element) throws java.lang.Exception
execute
in class teetime.framework.AbstractConsumerStage<IMonitoringRecord>
java.lang.Exception
public teetime.framework.OutputPort<IMonitoringRecord> getMatchingTraceIdOutputPort()
public teetime.framework.OutputPort<IMonitoringRecord> getMismatchingTraceIdOutputPort()
Copyright 2021 Kieker Project, http://kieker-monitoring.net