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