Kieker 1.5

kieker.tools.logReplayer
Class RealtimeReplayWorker

java.lang.Object
  extended by kieker.analysis.plugin.AbstractPlugin
      extended by kieker.analysis.plugin.filter.AbstractFilterPlugin
          extended by kieker.tools.logReplayer.RealtimeReplayWorker
All Implemented Interfaces:
Runnable, IFilterPlugin, IPlugin

public class RealtimeReplayWorker
extends AbstractFilterPlugin
implements Runnable

A Runnable to be scheduled via the RealtimeReplayDistributor TODO This plugin has to be rewritten in 1.6 to be initializable without further methods (initialize(...))

Author:
Robert von Massow

Nested Class Summary
 
Nested classes/interfaces inherited from interface kieker.analysis.plugin.IPlugin
IPlugin.PluginInputPortReference
 
Field Summary
static String OUTPUT_PORT_NAME
           
 
Fields inherited from class kieker.analysis.plugin.AbstractPlugin
CONFIG_NAME
 
Constructor Summary
RealtimeReplayWorker(Configuration configuration)
          Creates a new instance of this class using the given parameters.
 
Method Summary
 Configuration getCurrentConfiguration()
          This method should deliver a Configuration object containing the current configuration of this instance.
 void initialize(IMonitoringRecord record, RealtimeReplayDistributor replayDistributor, kieker.tools.logReplayer.FSReaderRealtime.FSReaderRealtimeCons cons, String constInputPortName, AnalysisController controller)
           
 void run()
           
 
Methods inherited from class kieker.analysis.plugin.filter.AbstractFilterPlugin
init, terminate
 
Methods inherited from class kieker.analysis.plugin.AbstractPlugin
areAllRepositoryPortsConnected, connect, connect, getAllInputPortNames, getAllOutputPortNames, getConnectedPlugins, getCurrentRepositories, getName, getPluginDescription, getPluginName, isConnectionAllowed
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

OUTPUT_PORT_NAME

public static final String OUTPUT_PORT_NAME
See Also:
Constant Field Values
Constructor Detail

RealtimeReplayWorker

public RealtimeReplayWorker(Configuration configuration)
Creates a new instance of this class using the given parameters. Further initialization should be done via the initialize-method.

Parameters:
configuration - The configuration object used to configure this instance.
Method Detail

initialize

public void initialize(IMonitoringRecord record,
                       RealtimeReplayDistributor replayDistributor,
                       kieker.tools.logReplayer.FSReaderRealtime.FSReaderRealtimeCons cons,
                       String constInputPortName,
                       AnalysisController controller)

run

public void run()
Specified by:
run in interface Runnable

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.

Specified by:
getCurrentConfiguration in interface IPlugin
Returns:
A completely filled configuration object.

Kieker 1.5

Copyright 2012 the Kieker Project, http://kieker-monitoring.net