org.globus.mds.aggregator.impl
Class QueryAggregatorSource

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

All Implemented Interfaces:

AggregatorSource

public class QueryAggregatorSource

extends PollingAggregatorSource

A PollingAggregatorSource that polls using WSRF resource property operations.

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

QueryAggregatorSource(AggregatorSink sink)

QueryAggregatorSource(AggregatorSink sink, Object sinkParameters)

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.
AnyContentType	poll(org.globus.mds.aggregator.types.AggregatorPollType parameters, EndpointReferenceType epr, org.globus.mds.aggregator.types.AggregatorConfig config) This method must be implemented by subclasses to provide the specific specialised poll implementation.
AnyContentType	pollGet(org.globus.mds.aggregator.types.AggregatorPollType parameters, EndpointReferenceType epr)
AnyContentType	pollGetMultiple(org.globus.mds.aggregator.types.AggregatorPollType parameters, EndpointReferenceType epr)
AnyContentType	pollQuery(org.globus.mds.aggregator.types.AggregatorPollType parameters, EndpointReferenceType epr)

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

QueryAggregatorSource

public QueryAggregatorSource(AggregatorSink sink,
                             Object sinkParameters)

QueryAggregatorSource

public QueryAggregatorSource(AggregatorSink sink)

Method Detail

poll

public AnyContentType poll(org.globus.mds.aggregator.types.AggregatorPollType parameters,
                           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

pollGet

public AnyContentType pollGet(org.globus.mds.aggregator.types.AggregatorPollType parameters,
                              EndpointReferenceType epr)

pollGetMultiple

public AnyContentType pollGetMultiple(org.globus.mds.aggregator.types.AggregatorPollType parameters,
                                      EndpointReferenceType epr)

pollQuery

public AnyContentType pollQuery(org.globus.mds.aggregator.types.AggregatorPollType parameters,
                                EndpointReferenceType epr)

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