T
- flow or operation execution typespublic abstract class AbstractTraceAnalysisStage<T>
extends teetime.framework.AbstractConsumerStage<T>
Constructor and Description |
---|
AbstractTraceAnalysisStage(SystemModelRepository systemModelRepository) |
Modifier and Type | Method and Description |
---|---|
protected Execution |
createExecutionByEntityNames(java.lang.String executionContainerName,
java.lang.String assemblyComponentTypeName,
Signature operationSignature,
long traceId,
java.lang.String sessionId,
int eoi,
int ess,
long tin,
long tout,
boolean assumed) |
protected Execution |
createExecutionByEntityNames(java.lang.String executionContainerName,
java.lang.String assemblyComponentTypeName,
java.lang.String componentTypeName,
Signature operationSignature,
long traceId,
java.lang.String sessionId,
int eoi,
int ess,
long tin,
long tout,
boolean assumed) |
static Execution |
createExecutionByEntityNames(SystemModelRepository systemModelRepository,
java.lang.String executionContainerName,
java.lang.String assemblyComponentTypeName,
Signature operationSignature,
long traceId,
java.lang.String sessionId,
int eoi,
int ess,
long tin,
long tout,
boolean assumed) |
static Execution |
createExecutionByEntityNames(SystemModelRepository systemModelRepository,
java.lang.String executionContainerName,
java.lang.String assemblyComponentTypeName,
java.lang.String componentTypeName,
Signature operationSignature,
long traceId,
java.lang.String sessionId,
int eoi,
int ess,
long tin,
long tout,
boolean assumed) |
SystemModelRepository |
getSystemModelRepository() |
protected void |
printDebugLogMessage(java.lang.String[] lines)
Prints a debug message to the logger.
|
protected void |
printErrorLogMessage(java.lang.String[] lines) |
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 AbstractTraceAnalysisStage(SystemModelRepository systemModelRepository)
public static final Execution createExecutionByEntityNames(SystemModelRepository systemModelRepository, java.lang.String executionContainerName, java.lang.String assemblyComponentTypeName, java.lang.String componentTypeName, Signature operationSignature, long traceId, java.lang.String sessionId, int eoi, int ess, long tin, long tout, boolean assumed)
public static final Execution createExecutionByEntityNames(SystemModelRepository systemModelRepository, java.lang.String executionContainerName, java.lang.String assemblyComponentTypeName, Signature operationSignature, long traceId, java.lang.String sessionId, int eoi, int ess, long tin, long tout, boolean assumed)
protected final Execution createExecutionByEntityNames(java.lang.String executionContainerName, java.lang.String assemblyComponentTypeName, java.lang.String componentTypeName, Signature operationSignature, long traceId, java.lang.String sessionId, int eoi, int ess, long tin, long tout, boolean assumed)
protected final Execution createExecutionByEntityNames(java.lang.String executionContainerName, java.lang.String assemblyComponentTypeName, Signature operationSignature, long traceId, java.lang.String sessionId, int eoi, int ess, long tin, long tout, boolean assumed)
protected void printDebugLogMessage(java.lang.String[] lines)
lines
- The lines to be printed.protected void printErrorLogMessage(java.lang.String[] lines)
public SystemModelRepository getSystemModelRepository()
Copyright 2021 Kieker Project, http://kieker-monitoring.net