public class InvalidEventRecordTraceCounter extends teetime.framework.AbstractConsumerStage<TraceEventRecords>
TraceEventRecords
.Constructor and Description |
---|
InvalidEventRecordTraceCounter(boolean logInvalidTraces)
Creates a new instance of this class using the given parameters.
|
Modifier and Type | Method and Description |
---|---|
protected void |
execute(TraceEventRecords invalidTrace) |
int |
getErrorCount()
Delivers the number of traces which have not been processed
successfully.
|
long |
getLastTraceIdError()
Delivers the ID of the last trace which has not been processed
successfully.
|
int |
getTotalCount()
Delivers the total number of traces which have been processed.
|
protected void |
onTerminating() |
protected void |
reportError(long traceId)
This method can be used to report a trace which has not been processed
successfully.
|
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 InvalidEventRecordTraceCounter(boolean logInvalidTraces)
logInvalidTraces
- if true invalid traces are logged in the error logprotected void execute(TraceEventRecords invalidTrace) throws java.lang.Exception
execute
in class teetime.framework.AbstractConsumerStage<TraceEventRecords>
java.lang.Exception
protected void onTerminating()
onTerminating
in class teetime.framework.AbstractStage
protected final void reportError(long traceId)
traceId
- The ID of the processed trace.public final int getErrorCount()
public final int getTotalCount()
public final long getLastTraceIdError()
Copyright 2021 Kieker Project, http://kieker-monitoring.net