org.globus.mds.aggregator.impl
Class ServiceGroupEntryAggregatorSink

java.lang.Object
  org.globus.mds.aggregator.impl.ServiceGroupEntryAggregatorSink

All Implemented Interfaces:

AggregatorSink

public class ServiceGroupEntryAggregatorSink

extends java.lang.Object

implements AggregatorSink

The ServiceGroupEntryAggregatorSink stores aggregate data as ServiceGroupEntry content.

Field Summary

private boolean	initialized
private static org.apache.commons.logging.Log	logger
private AggregatorSource	source

Constructor Summary

ServiceGroupEntryAggregatorSink()
Creates a new instance of ServiceGroupEntryAggregatorSink

Method Summary

void	deliver(org.apache.axis.encoding.AnyContentType message, AggregatorServiceGroupEntryResource entry) Should be called by an AggregatorSource to deliver 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 AggregatorSink class.
AggregatorSource	getSource() Gets the AggregatorSource connected to this sink
void	initialize(java.lang.Object parameters) Called to initialize any necessary state.
void	setSource(AggregatorSource source) Sets the AggregatorSource connected to this sink
void	terminate() Called to free resources used by the sink.

Methods inherited from class java.lang.Object

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

Field Detail

source

private AggregatorSource source

initialized

private boolean initialized

logger

private static org.apache.commons.logging.Log logger

Constructor Detail

ServiceGroupEntryAggregatorSink

public ServiceGroupEntryAggregatorSink()

Creates a new instance of ServiceGroupEntryAggregatorSink

Method Detail

initialize

public void initialize(java.lang.Object parameters)
                throws AggregatorException,
                       java.lang.Exception

Description copied from interface: AggregatorSink

Called to initialize any necessary state. This method should throw an exception if the host AggregatorSource is not set. The underlying implementation may also throw an exception during initialization if it is not compatible with the host AggregationSource. The implementation may use the optional parameters Object to read implementation specific data or can just ignore processing it altogether. TODO: add custom exceptions here like SourceNotSet and SourceTypeNotSupported

Specified by:

initialize in interface AggregatorSink

Throws:

AggregatorException

java.lang.Exception

getSource

public AggregatorSource getSource()

Description copied from interface: AggregatorSink

Gets the AggregatorSource connected to this sink

Specified by:

getSource in interface AggregatorSink

setSource

public void setSource(AggregatorSource source)

Description copied from interface: AggregatorSink

Sets the AggregatorSource connected to this sink

Specified by:

setSource in interface AggregatorSink

deliver

public void deliver(org.apache.axis.encoding.AnyContentType message,
                    AggregatorServiceGroupEntryResource entry)
             throws AggregatorException,
                    java.lang.Exception

Description copied from interface: AggregatorSink

Should be called by an AggregatorSource to deliver 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 AggregatorSink class. The context parameter is the AggregatorServiceGroupEntryResource context parameter passed to the hosting AggregationSource when the AggregationSource.addAggregation method is invoked.

Specified by:

deliver in interface AggregatorSink

Throws:

AggregatorException

java.lang.Exception

terminate

public void terminate()

Description copied from interface: AggregatorSink

Called to free resources used by the sink.

Specified by:

terminate in interface AggregatorSink