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

java.lang.Object
  extended byorg.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(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.
 
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(org.globus.ogsa.GridServiceBase serviceBase)
                throws org.globus.ogsa.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:
org.globus.ogsa.GridServiceException

deliver

public void deliver(org.gridforum.ogsi.ExtensibilityType message,
                    java.lang.String sessionID)
             throws org.globus.ogsa.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:
org.globus.ogsa.GridServiceException