G
- The graph type created by this filterpublic abstract class AbstractGraphProducingFilter<G extends AbstractGraph<?,?,?>> extends AbstractMessageTraceProcessingFilter implements IGraphProducingFilter<G>
IPlugin.PluginInputPortReference, IPlugin.STATE
INPUT_PORT_NAME_MESSAGE_TRACES
CONFIG_PROPERTY_VALUE_VERBOSE, LOG, REPOSITORY_PORT_NAME_SYSTEM_MODEL
CONFIG_NAME, configuration, log, projectContext, recordsTimeUnitFromProjectContext
OUTPUT_PORT_NAME_GRAPH
Constructor and Description |
---|
AbstractGraphProducingFilter(Configuration configuration,
IProjectContext projectContext,
G graph)
Creates a new graph-producing filter using the given configuration and the given graph.
|
Modifier and Type | Method and Description |
---|---|
abstract java.lang.String |
getConfigurationName()
Returns this filter's configuration name.
|
protected G |
getGraph()
Delivers the graph stored in this filter.
|
java.lang.String |
getGraphOutputPortName()
Returns the name of the port this filter uses to emit the graph.
|
protected IOriginRetentionPolicy |
getOriginRetentionPolicy() |
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.
|
void |
terminate(boolean error)
Initiates a termination of the plugin.
|
inputMessageTraces
getErrorCount, getLastTraceIdError, getLastTraceIdSuccess, getSuccessCount, getTotalCount, printStatusMessage, reportError, reportSuccess
createExecutionByEntityNames, createExecutionByEntityNames, createExecutionByEntityNames, createExecutionByEntityNames, getCurrentConfiguration, getSystemEntityFactory, printDebugLogMessage, printErrorLogMessage
init
areAllRepositoryPortsConnected, connect, connect, deliver, getAllDisplayNames, getAllInputPortNames, getAllOutputPortNames, getAllRepositoryPortNames, getConnectedPlugins, getCurrentRepositories, getDefaultConfiguration, getIncomingPlugins, getPluginDescription, getPluginName, getRepository, getState, isConnectionAllowed, notifyNewIncomingConnection, notifyNewOutgoingConnection, shutdown, start
getName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connect, getAllDisplayNames, getAllInputPortNames, getAllOutputPortNames, getAllRepositoryPortNames, getConnectedPlugins, getCurrentRepositories, getName, getPluginDescription, getPluginName, getState
public AbstractGraphProducingFilter(Configuration configuration, IProjectContext projectContext, G graph)
configuration
- The configuration to useprojectContext
- The project context to use.graph
- The (usually empty) graph to produce / extendpublic abstract java.lang.String getConfigurationName()
public void terminate(boolean error)
AbstractFilterPlugin
AnalysisController.terminate(boolean)
instead.
After receiving this notification, the plugin should terminate any running
methods, e.g., read for readers.terminate
in interface IPlugin
terminate
in class AbstractFilterPlugin
error
- Determines whether the plugin is terminated due to an error or not.public java.lang.String getGraphOutputPortName()
IGraphOutputtingFilter
getGraphOutputPortName
in interface IGraphOutputtingFilter<G extends AbstractGraph<?,?,?>>
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 2017 Kieker Project, http://kieker-monitoring.net