kieker.analysis.plugin.reader
Class AbstractReaderPlugin

java.lang.Object
  kieker.analysis.plugin.AbstractPlugin
      kieker.analysis.plugin.reader.AbstractReaderPlugin

All Implemented Interfaces:

IPlugin, IReaderPlugin

Direct Known Subclasses:

DbReader, FSReader, JMSReader, JMXReader, ListReader, PipeReader

public abstract class AbstractReaderPlugin
extends AbstractPlugin
implements IReaderPlugin

This class should be used as a base for every reader used within Kieker.

Author:

Nils Christian Ehmke

Nested Class Summary

Nested classes/interfaces inherited from interface kieker.analysis.plugin.IPlugin

IPlugin.PluginInputPortReference, IPlugin.STATE

Field Summary

Fields inherited from class kieker.analysis.plugin.AbstractPlugin

CONFIG_NAME

Constructor Summary

AbstractReaderPlugin(Configuration configuration)
Each Plugin requires a constructor with a single Configuration object.

Method Summary

boolean

init() Initiates the start of a component.

Methods inherited from class kieker.analysis.plugin.AbstractPlugin

areAllRepositoryPortsConnected, connect, connect, getAllDisplayNames, getAllInputPortNames, getAllOutputPortNames, getAllRepositoryPortNames, getConnectedPlugins, getCurrentRepositories, getIncomingPlugins, getName, getPluginDescription, getPluginName, getState, isConnectionAllowed, shutdown, start

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface kieker.analysis.plugin.reader.IReaderPlugin

read

Methods inherited from interface kieker.analysis.plugin.IPlugin

getCurrentConfiguration, terminate

Constructor Detail

AbstractReaderPlugin

public AbstractReaderPlugin(Configuration configuration)

Each Plugin requires a constructor with a single Configuration object.

Parameters:

configuration - The configuration which should be used to initialize the object.

Method Detail

init

public boolean init()

Description copied from interface: IPlugin

Initiates the start of a component. This method is called once when a AnalysisController's run() method is called. This implementation must not be blocking! Asynchronous consumers would spawn (an) asynchronous thread(s) in this method.

Specified by:

init in interface IPlugin

Returns:

true on success; false otherwise.