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/interfaces inherited from class org.globus.mds.aggregator.impl.PollingAggregatorSource

PollingAggregatorSource.QueryTimerListener

Field Summary

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

localEPR

private org.globus.axis.message.addressing.EndpointReferenceType localEPR

Constructor Detail

QueryAggregatorSource

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

QueryAggregatorSource

public QueryAggregatorSource(AggregatorSink sink)

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 parameters,
                                                    org.globus.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.globus.axis.message.addressing.EndpointReferenceType epr)

pollGetMultiple

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

pollQuery

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