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

private java.lang.String	baseDir
private static org.apache.commons.logging.Log	logger
private java.util.Hashtable	probeTable

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

AggregatorPollType	deserializeParameter(org.apache.axis.message.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(java.lang.Object parameters) Called to initialize any necessary state.
org.apache.axis.encoding.AnyContentType	poll(AggregatorPollType pollParameters, org.apache.axis.message.addressing.EndpointReferenceType epr, 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

Field Detail

logger

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

probeTable

private java.util.Hashtable probeTable

baseDir

private java.lang.String baseDir

Constructor Detail

ExecutionAggregatorSource

public ExecutionAggregatorSource(AggregatorSink sink)

Creates a new instance of ExecutionAggregatorSource

Method Detail

initialize

public void initialize(java.lang.Object parameters)
                throws AggregatorException,
                       java.lang.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

java.lang.Exception

poll

public org.apache.axis.encoding.AnyContentType poll(AggregatorPollType pollParameters,
                                                    org.apache.axis.message.addressing.EndpointReferenceType epr,
                                                    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 AggregatorPollType deserializeParameter(org.apache.axis.message.MessageElement m)
                                        throws 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:

DeserializationException