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(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(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(GridServiceBase serviceBase)
                throws 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:

GridServiceException

deliver

public void deliver(ExtensibilityType message,
                    java.lang.String sessionID)
             throws 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:

GridServiceException