kieker.analysis.plugin.filter.forward
Class RealtimeRecordDelayFilter
java.lang.Object
kieker.analysis.plugin.AbstractPlugin
kieker.analysis.plugin.filter.AbstractFilterPlugin
kieker.analysis.plugin.filter.forward.RealtimeRecordDelayFilter
- All Implemented Interfaces:
- IFilterPlugin, IPlugin
public class RealtimeRecordDelayFilter
- extends AbstractFilterPlugin
Forwards incoming IMonitoringRecord
s with delays computed from the IMonitoringRecord.getLoggingTimestamp()
value
(assumed to be in nanoseconds resolution). For example, after initialization, if records with logging timestamps 3000 and 4500 nanos are received, the
first record is forwarded immediately; the second will be forwarded 1500 nanos later.
- Author:
- Andre van Hoorn, Robert von Massow
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 |
INPUT_PORT_NAME_RECORDS
public static final String INPUT_PORT_NAME_RECORDS
- See Also:
- Constant Field Values
OUTPUT_PORT_NAME_RECORDS
public static final String OUTPUT_PORT_NAME_RECORDS
- See Also:
- Constant Field Values
CONFIG_PROPERTY_NAME_NUM_WORKERS
public static final String CONFIG_PROPERTY_NAME_NUM_WORKERS
- The number of threads to be used for the internal
ThreadPoolExecutor
, processing the scheduled IMonitoringRecord
s.
- See Also:
- Constant Field Values
CONFIG_PROPERTY_NAME_ADDITIONAL_SHUTDOWN_DELAY_SECONDS
public static final String CONFIG_PROPERTY_NAME_ADDITIONAL_SHUTDOWN_DELAY_SECONDS
- The number of additional seconds to wait before execute the termination (after all records have been forwarded)
- See Also:
- Constant Field Values
RealtimeRecordDelayFilter
public RealtimeRecordDelayFilter(Configuration configuration)
inputRecord
public final void inputRecord(IMonitoringRecord monitoringRecord)
terminate
public void terminate(boolean error)
- Description copied from interface:
IPlugin
- Initiates a termination of the plugin. This method is only used by the
framework and should not be called manually.
Use the method
AnalysisController.terminate(boolean)
instead.
After receiving this notification, the plugin should terminate any running
methods, e.g., read for readers.
- Specified by:
terminate
in interface IPlugin
- Overrides:
terminate
in class AbstractFilterPlugin
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 Kieker Project, http://kieker-monitoring.net>