org.globus.mds.aggregator.impl
Class ExecutionAggregatorSource

java.lang.Object
  org.globus.mds.aggregator.impl.PollingAggregatorSource
      org.globus.mds.aggregator.impl.ExecutionAggregatorSource

All Implemented Interfaces:

AggregatorSource

public class ExecutionAggregatorSource

extends PollingAggregatorSource

An AggregatorSource which generates data using synchronous poll-style execution of an administrator-configured script.

Nested Class Summary

Nested classes inherited from class org.globus.mds.aggregator.impl.PollingAggregatorSource

PollingAggregatorSource.QueryTimerListener

Field Summary

Fields inherited from class org.globus.mds.aggregator.impl.PollingAggregatorSource

DEFAULT_POLL_INTERVAL

Constructor Summary

ExecutionAggregatorSource(AggregatorSink sink)
Creates a new instance of ExecutionAggregatorSource

Method Summary

org.globus.mds.aggregator.types.AggregatorPollType	deserializeParameter(MessageElement m) If the supplied message element is a supported parameter block, the deserialised form should be returned; otherwise null should be returned.
void	initialize(Object parameters) Called to initialize any necessary state.
AnyContentType	poll(org.globus.mds.aggregator.types.AggregatorPollType pollParameters, EndpointReferenceType epr, org.globus.mds.aggregator.types.AggregatorConfig config) This method must be implemented by subclasses to provide the specific specialised poll implementation.

Methods inherited from class org.globus.mds.aggregator.impl.PollingAggregatorSource

addAggregation, getAggregatorSink, getSessionContext, getSessionKey, isValidSession, removeAggregation, setAggregatorSink, terminate

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutionAggregatorSource

public ExecutionAggregatorSource(AggregatorSink sink)

Creates a new instance of ExecutionAggregatorSource

Method Detail

initialize

public void initialize(Object parameters)
                throws AggregatorException,
                       Exception

Description copied from interface: AggregatorSource

Called to initialize any necessary state. This method should also attempt to initialize the specified sink and should always throw an exception if the sink is not set. The underlying implementation should throw an AggregatorSinkTypeNotSupportedException if it is not compatible with the supplied AggregationSink. The implementation may use the optional parameters Object to read implementation specific data from or just ignore the processing of it altogether.

Specified by:

initialize in interface AggregatorSource

Overrides:

initialize in class PollingAggregatorSource

Throws:

AggregatorException

Exception

poll

public AnyContentType poll(org.globus.mds.aggregator.types.AggregatorPollType pollParameters,
                           EndpointReferenceType epr,
                           org.globus.mds.aggregator.types.AggregatorConfig config)

Description copied from class: PollingAggregatorSource

This method must be implemented by subclasses to provide the specific specialised poll implementation. It will be called by the PollingAggregatorSource implementation every time it is time to poll for data. TODO: this method signature is getting a little messy... tidy up

Specified by:

poll in class PollingAggregatorSource

deserializeParameter

public org.globus.mds.aggregator.types.AggregatorPollType deserializeParameter(MessageElement m)
                                                                        throws org.globus.wsrf.encoding.DeserializationException

Description copied from class: PollingAggregatorSource

If the supplied message element is a supported parameter block, the deserialised form should be returned; otherwise null should be returned. This method will be invoked on all config parameters supplied to an aggregation until one is found that matches.

Specified by:

deserializeParameter in class PollingAggregatorSource

Throws:

org.globus.wsrf.encoding.DeserializationException