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

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

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

DEFAULT_POLL_INTERVAL

Constructor Summary

QueryAggregatorSource(AggregatorSink sink)

QueryAggregatorSource(AggregatorSink sink, java.lang.Object sinkParameters)

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.
org.apache.axis.encoding.AnyContentType	poll(AggregatorPollType parameters, org.apache.axis.message.addressing.EndpointReferenceType epr, AggregatorConfig config) This method must be implemented by subclasses to provide the specific specialised poll implementation.
org.apache.axis.encoding.AnyContentType	pollGet(AggregatorPollType parameters, org.apache.axis.message.addressing.EndpointReferenceType epr)
org.apache.axis.encoding.AnyContentType	pollGetMultiple(AggregatorPollType parameters, org.apache.axis.message.addressing.EndpointReferenceType epr)
org.apache.axis.encoding.AnyContentType	pollQuery(AggregatorPollType parameters, org.apache.axis.message.addressing.EndpointReferenceType epr)
private void	setAnonymous(javax.xml.rpc.Stub stub)

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

Field Detail

logger

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

wsloc

private static WSResourcePropertiesServiceAddressingLocator wsloc

Constructor Detail

QueryAggregatorSource

public QueryAggregatorSource(AggregatorSink sink,
                             java.lang.Object sinkParameters)

QueryAggregatorSource

public QueryAggregatorSource(AggregatorSink sink)

Method Detail

poll

public org.apache.axis.encoding.AnyContentType poll(AggregatorPollType parameters,
                                                    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

pollGet

public org.apache.axis.encoding.AnyContentType pollGet(AggregatorPollType parameters,
                                                       org.apache.axis.message.addressing.EndpointReferenceType epr)

pollGetMultiple

public org.apache.axis.encoding.AnyContentType pollGetMultiple(AggregatorPollType parameters,
                                                               org.apache.axis.message.addressing.EndpointReferenceType epr)

pollQuery

public org.apache.axis.encoding.AnyContentType pollQuery(AggregatorPollType parameters,
                                                         org.apache.axis.message.addressing.EndpointReferenceType epr)

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

setAnonymous

private void setAnonymous(javax.xml.rpc.Stub stub)