org.globus.ogsa.impl.base.aggregator
Class ServiceDataAggregationSink

java.lang.Object
  org.globus.ogsa.impl.base.aggregator.ServiceDataAggregationSink

All Implemented Interfaces:

DataAggregationSink

public class ServiceDataAggregationSink

extends java.lang.Object

implements DataAggregationSink

DataAggregationSink which republishes aggregated SDEs as the same SDEs on the local service.

Constructor Summary

ServiceDataAggregationSink()

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ServiceDataAggregationSink

public ServiceDataAggregationSink()

Method Detail

initialize

public void initialize(GridServiceBase serviceBase)
                throws GridServiceException

Description copied from interface: DataAggregationSink

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.

Specified by:

initialize in interface DataAggregationSink

Throws:

GridServiceException

deliver

public void deliver(ExtensibilityType message,
                    java.lang.String sessionID)
             throws GridServiceException

Description copied from interface: DataAggregationSink

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.

Specified by:

deliver in interface DataAggregationSink

Throws:

GridServiceException