org.ow2.clif.datacollector.lib
Class AbstractDataCollector

java.lang.Object
  extended by org.ow2.clif.datacollector.lib.AbstractDataCollector
All Implemented Interfaces:
org.objectweb.fractal.api.control.BindingController, org.objectweb.fractal.api.control.LifeCycleController, DataCollectorAdmin, DataCollectorWrite
Direct Known Subclasses:
AbstractProbeDataCollector, InjectorDataCollector

public abstract class AbstractDataCollector
extends java.lang.Object
implements DataCollectorWrite, DataCollectorAdmin, org.objectweb.fractal.api.control.BindingController, org.objectweb.fractal.api.control.LifeCycleController

Abstract implementation of a Data Collector component.

Author:
Bruno Dillenseger

Field Summary
protected  StorageWrite sws
           
 
Fields inherited from interface org.ow2.clif.datacollector.api.DataCollectorWrite
DATA_COLLECTOR_WRITE
 
Fields inherited from interface org.ow2.clif.datacollector.api.DataCollectorAdmin
DATA_COLLECTOR_ADMIN
 
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController
STARTED, STOPPED
 
Constructor Summary
AbstractDataCollector()
           
 
Method Summary
 void add(ActionEvent action)
          Add a new measure - simply transmit it to the Storage Proxy component unless it is rejected by current DataCollectorFilter.
 void add(AlarmEvent alarm)
          Add a new alarm - simply transmit it to the Storage Proxy component unless it is rejected by current DataCollectorFilter.
 void add(LifeCycleEvent event)
          Add a new lifecycle event - simply forwards it to the Storage Proxy component unless it is rejected by current DataCollectorFilter.
 void add(ProbeEvent measure)
          Add a new measure - simply transmit it to the Storage Proxy component unless it is null or it is rejected by current DataCollectorFilter.
 void bindFc(java.lang.String clientItfName, java.lang.Object serverItf)
           
 java.lang.String getFcState()
           
 void init(java.io.Serializable testId, java.lang.String bladeId)
          Initialize a test
 java.lang.String[] listFc()
           
 java.lang.Object lookupFc(java.lang.String clientItfName)
           
 void setFilter(DataCollectorFilter filter)
          Sets a filter selecting generated events forwarded to Storage
 void startFc()
           
 void stopFc()
           
 void terminate()
          Does nothing.
 void unbindFc(java.lang.String clientItfName)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.ow2.clif.datacollector.api.DataCollectorAdmin
getLabels, getStat
 

Field Detail

sws

protected StorageWrite sws
Constructor Detail

AbstractDataCollector

public AbstractDataCollector()
Method Detail

startFc

public void startFc()
Specified by:
startFc in interface org.objectweb.fractal.api.control.LifeCycleController

stopFc

public void stopFc()
Specified by:
stopFc in interface org.objectweb.fractal.api.control.LifeCycleController

getFcState

public java.lang.String getFcState()
Specified by:
getFcState in interface org.objectweb.fractal.api.control.LifeCycleController

lookupFc

public java.lang.Object lookupFc(java.lang.String clientItfName)
Specified by:
lookupFc in interface org.objectweb.fractal.api.control.BindingController

bindFc

public void bindFc(java.lang.String clientItfName,
                   java.lang.Object serverItf)
Specified by:
bindFc in interface org.objectweb.fractal.api.control.BindingController

unbindFc

public void unbindFc(java.lang.String clientItfName)
Specified by:
unbindFc in interface org.objectweb.fractal.api.control.BindingController

listFc

public java.lang.String[] listFc()
Specified by:
listFc in interface org.objectweb.fractal.api.control.BindingController

init

public void init(java.io.Serializable testId,
                 java.lang.String bladeId)
Description copied from interface: DataCollectorWrite
Initialize a test

Specified by:
init in interface DataCollectorWrite
Parameters:
testId - test identifier
bladeId - blade identifier

terminate

public void terminate()
Does nothing.

Specified by:
terminate in interface DataCollectorWrite

add

public void add(LifeCycleEvent event)
Add a new lifecycle event - simply forwards it to the Storage Proxy component unless it is rejected by current DataCollectorFilter.

Specified by:
add in interface DataCollectorWrite
Parameters:
event - new lifecycle event

add

public void add(ActionEvent action)
Add a new measure - simply transmit it to the Storage Proxy component unless it is rejected by current DataCollectorFilter.

Specified by:
add in interface DataCollectorWrite
Parameters:
action - the new action event

add

public void add(AlarmEvent alarm)
Add a new alarm - simply transmit it to the Storage Proxy component unless it is rejected by current DataCollectorFilter.

Specified by:
add in interface DataCollectorWrite
Parameters:
alarm - new alarm event

add

public void add(ProbeEvent measure)
Add a new measure - simply transmit it to the Storage Proxy component unless it is null or it is rejected by current DataCollectorFilter.

Specified by:
add in interface DataCollectorWrite
Parameters:
measure - the new measure

setFilter

public void setFilter(DataCollectorFilter filter)
Description copied from interface: DataCollectorWrite
Sets a filter selecting generated events forwarded to Storage

Specified by:
setFilter in interface DataCollectorWrite
Parameters:
filter - event filter; a null filter forwards all events to Storage