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.
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 |
ServiceDataAggregationSink
public ServiceDataAggregationSink()
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