T
- an AbstractTrace typepublic abstract class AbstractTraceProcessingStage<T> extends AbstractTraceAnalysisStage<T>
Constructor and Description |
---|
AbstractTraceProcessingStage(SystemModelRepository systemModelRepository)
Creates a new instance of this class using the given parameters.
|
Modifier and Type | Method and Description |
---|---|
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.
|
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.
|
void |
printStatusMessage()
Returns a user-addressed status message to be logged by the calling tool.
|
protected void |
reportError(long traceId)
This method can be used to report a trace which has not been processed
successfully.
|
protected void |
reportSuccess(long traceId)
This method can be used to report a trace which has been processed
successfully.
|
createExecutionByEntityNames, createExecutionByEntityNames, createExecutionByEntityNames, createExecutionByEntityNames, getSystemModelRepository, printDebugLogMessage, printErrorLogMessage
createInputPort, execute, 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 AbstractTraceProcessingStage(SystemModelRepository systemModelRepository)
systemModelRepository
- the model repository to be usedprotected final void reportSuccess(long traceId)
traceId
- The ID of the processed trace.protected final void reportError(long traceId)
traceId
- The ID of the processed trace.public final int getSuccessCount()
public final int getErrorCount()
public final int getTotalCount()
public final long getLastTraceIdError()
public final long getLastTraceIdSuccess()
public void printStatusMessage()
Copyright 2021 Kieker Project, http://kieker-monitoring.net