G
- The graph type created by this filterpublic abstract class AbstractGraphProducingFilter<G extends AbstractGraph<?,?,?>> extends AbstractMessageTraceProcessingFilter implements IGraphProducingFilter<G>
Constructor and Description |
---|
AbstractGraphProducingFilter(SystemModelRepository repository,
G graph)
Creates a new graph-producing filter using the given configuration and the
given graph.
|
Modifier and Type | Method and Description |
---|---|
protected G |
getGraph()
Delivers the graph stored in this filter.
|
protected IOriginRetentionPolicy |
getOriginRetentionPolicy() |
teetime.framework.OutputPort<G> |
getOutputPort() |
protected <T> void |
handleOrigin(AbstractGraphElement<T> element,
T origin) |
void |
requestOriginRetentionPolicy(IOriginRetentionPolicy policy)
Requests that the given retention policy is used by this graph producer.
|
execute
getErrorCount, getLastTraceIdError, getLastTraceIdSuccess, getSuccessCount, getTotalCount, printStatusMessage, reportError, reportSuccess
createExecutionByEntityNames, createExecutionByEntityNames, createExecutionByEntityNames, createExecutionByEntityNames, getSystemModelRepository, printDebugLogMessage, printErrorLogMessage
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, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted
public AbstractGraphProducingFilter(SystemModelRepository repository, G graph)
repository
- model repositorygraph
- The (usually empty) graph to produce / extendpublic teetime.framework.OutputPort<G> getOutputPort()
protected G getGraph()
protected IOriginRetentionPolicy getOriginRetentionPolicy()
public void requestOriginRetentionPolicy(IOriginRetentionPolicy policy) throws AnalysisConfigurationException
IGraphProducingFilter
IOriginRetentionPolicy.isCompatibleWith(IOriginRetentionPolicy)
).requestOriginRetentionPolicy
in interface IGraphProducingFilter<G extends AbstractGraph<?,?,?>>
policy
- The requested policyAnalysisConfigurationException
- If an error occurs during the requestprotected <T> void handleOrigin(AbstractGraphElement<T> element, T origin)
Copyright 2021 Kieker Project, http://kieker-monitoring.net