kieker.tools.logReplayer
Class RealtimeReplayDistributor
java.lang.Object
kieker.analysis.plugin.AbstractPlugin
kieker.analysis.plugin.filter.AbstractFilterPlugin
kieker.tools.logReplayer.RealtimeReplayDistributor
- All Implemented Interfaces:
- IFilterPlugin, IPlugin
public class RealtimeReplayDistributor
- extends AbstractFilterPlugin
IMonitoringRecordConsumerPlugin that distributes the log records to the worker thread for "real time" replays.
This class has exactly one input port named "in" and one output ports named "out".
TODO: Currently this class can not be used for the later analysis tool, as the objects for the constructor cannot be configured with a configuration
object.
- Author:
- Robert von Massow
Methods inherited from class kieker.analysis.plugin.AbstractPlugin |
areAllRepositoryPortsConnected, connect, connect, getAllInputPortNames, getAllOutputPortNames, getConnectedPlugins, getCurrentRepositories, getName, getPluginDescription, getPluginName, isConnectionAllowed |
INPUT_PORT_NAME_MONITORING_RECORDS
public static final String INPUT_PORT_NAME_MONITORING_RECORDS
- See Also:
- Constant Field Values
CONFIG_PROPERTY_NAME_NUM_WORKERS
public static final String CONFIG_PROPERTY_NAME_NUM_WORKERS
- See Also:
- Constant Field Values
RealtimeReplayDistributor
public RealtimeReplayDistributor(Configuration configuration)
- Constructs a RealtimeReplayDistributor.
- Parameters:
configuration
- The configuration object used to configure this instance.
setCons
public void setCons(kieker.tools.logReplayer.FSReaderRealtime.FSReaderRealtimeCons cons)
setConstInputPortName
public void setConstInputPortName(String constInputPortName)
setTerminationLatch
public void setTerminationLatch(CountDownLatch terminationLatch)
setController
public void setController(AnalysisController controller)
inputMonitoringRecords
public void inputMonitoringRecords(IMonitoringRecord monitoringRecord)
getOffset
public final long getOffset()
getStartTime
public final long getStartTime()
terminate
public void terminate(boolean error)
- Description copied from interface:
IFilterPlugin
- Initiates a termination of the component. The value of the parameter
error indicates whether an error occurred.
- Specified by:
terminate
in interface IFilterPlugin
- Overrides:
terminate
in class AbstractFilterPlugin
- Parameters:
error
- true iff an error occurred.
decreaseActive
public void decreaseActive()
getNumWorkers
public int getNumWorkers()
getCurrentConfiguration
public Configuration getCurrentConfiguration()
- Description copied from interface:
IPlugin
- This method should deliver a
Configuration
object containing the current configuration of this instance. In other words: The constructor should be
able to use the given object to initialize a new instance of this class with the same intern properties.
- Returns:
- A completely filled configuration object.
Copyright 2012 the Kieker Project, http://kieker-monitoring.net>