org.globus.ogsa.impl.base.aggregator
Interface DataAggregationSink

All Known Implementing Classes:
ServiceDataAggregationSink

public interface DataAggregationSink

The interface that must be implemented by a plugin for the collector component of the aggregator, in order to act as an aggregator formatter.


Method Summary
 void deliver(org.gridforum.ogsi.ExtensibilityType message, java.lang.String sessionID)
          Delivers a message with the assumption that the message data will be aggregated as its native type and into whatever data storage format is used by the underlying DataAggregationSink class.
 void initialize(org.globus.ogsa.GridServiceBase serviceBase)
          Called after the aggregator manager has initialized itself, to give the DataAggregationSink a chance to initialize any necessary state from the context of the GridServiceBase parameter.
 

Method Detail

initialize

public void initialize(org.globus.ogsa.GridServiceBase serviceBase)
                throws org.globus.ogsa.GridServiceException
Called after the aggregator manager has initialized itself, to give the DataAggregationSink a chance to initialize any necessary state from the context of the GridServiceBase parameter.

Throws:
org.globus.ogsa.GridServiceException

deliver

public void deliver(org.gridforum.ogsi.ExtensibilityType message,
                    java.lang.String sessionID)
             throws org.globus.ogsa.GridServiceException
Delivers a message with the assumption that the message data will be aggregated as its native type and into whatever data storage format is used by the underlying DataAggregationSink class.

Throws:
org.globus.ogsa.GridServiceException