Kieker 1.2

kieker.tools.traceAnalysis.plugins.executionRecordTransformation
Class ExecutionRecordTransformationFilter

java.lang.Object
  extended by kieker.tools.traceAnalysis.plugins.AbstractTraceAnalysisPlugin
      extended by kieker.tools.traceAnalysis.plugins.executionRecordTransformation.ExecutionRecordTransformationFilter
All Implemented Interfaces:
IAnalysisPlugin, IMonitoringRecordConsumerPlugin, IMonitoringRecordReceiver

public class ExecutionRecordTransformationFilter
extends AbstractTraceAnalysisPlugin
implements IMonitoringRecordConsumerPlugin

Transforms KiekerExecutionRecords into Execution objects.

Author:
Andre van Hoorn

Constructor Summary
ExecutionRecordTransformationFilter(String name, SystemModelRepository systemFactory)
           
 
Method Summary
 boolean execute()
          Initiates the start of a component.
 IOutputPort<Execution> getExecutionOutputPort()
           
 Collection<Class<? extends IMonitoringRecord>> getRecordTypeSubscriptionList()
          Simply return null to get records of all types.
 boolean newMonitoringRecord(IMonitoringRecord record)
          Called for each new record.
 void terminate(boolean error)
          Initiates a termination of the component.
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ExecutionRecordTransformationFilter

public ExecutionRecordTransformationFilter(String name,
                                           SystemModelRepository systemFactory)
Method Detail

getRecordTypeSubscriptionList

public Collection<Class<? extends IMonitoringRecord>> getRecordTypeSubscriptionList()
Description copied from interface: IMonitoringRecordConsumerPlugin
Simply return null to get records of all types.

Specified by:
getRecordTypeSubscriptionList in interface IMonitoringRecordConsumerPlugin
Returns:

newMonitoringRecord

public boolean newMonitoringRecord(IMonitoringRecord record)
Description copied from interface: IMonitoringRecordReceiver
Called for each new record. Notice, that this method should not throw an exception, but indicate an error by the return value false.

Specified by:
newMonitoringRecord in interface IMonitoringRecordReceiver
Parameters:
record - the record.
Returns:
true on success; false in case of an error.

execute

public boolean execute()
Description copied from interface: IAnalysisPlugin
Initiates the start of a component. This method is called once when a TpanInstance's run() method is called. This implementation must not be blocking! Asynchronous consumers would spawn (an) aynchronous thread(s) in this method.

Specified by:
execute in interface IAnalysisPlugin
Returns:
true on success; false otherwise.

terminate

public void terminate(boolean error)
Description copied from interface: IAnalysisPlugin
Initiates a termination of the component. The value of the parameter error indicates whether an error occured.

Specified by:
terminate in interface IAnalysisPlugin
Parameters:
error - true iff an error occured.

getExecutionOutputPort

public IOutputPort<Execution> getExecutionOutputPort()

Kieker 1.2

Copyright 2010 the Kieker Project, http://kieker.sourceforge.net