org.globus.mds.aggregator.impl
Class PollingAggregatorSource.QueryTimerListener

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

All Implemented Interfaces:

commonj.timers.TimerListener

Enclosing class:

PollingAggregatorSource

public class PollingAggregatorSource.QueryTimerListener

extends Object

implements commonj.timers.TimerListener

One instance of this class will be created for each aggregation

Field Summary

String

sessionKey The session.

Constructor Summary

PollingAggregatorSource.QueryTimerListener(org.globus.mds.aggregator.types.AggregatorPollType parameters, AggregatorServiceGroupEntryResource entry, org.globus.mds.aggregator.types.AggregatorConfig config)

Method Summary

AggregatorServiceGroupEntryResource	getEntry()
org.globus.mds.aggregator.types.AggregatorPollType	getParameters()
String	getSessionKey()
commonj.timers.Timer	getTimer()
void	setTimer(commonj.timers.Timer t)
void	timerExpired(commonj.timers.Timer timer)

Methods inherited from class java.lang.Object

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

Field Detail

sessionKey

public final String sessionKey

The session. This will be the string QTL followed by the hash code of this object. 'QTL' is prepended in order to provide some disambiguation in debugging output

Constructor Detail

PollingAggregatorSource.QueryTimerListener

public PollingAggregatorSource.QueryTimerListener(org.globus.mds.aggregator.types.AggregatorPollType parameters,
                                                  AggregatorServiceGroupEntryResource entry,
                                                  org.globus.mds.aggregator.types.AggregatorConfig config)

Method Detail

getSessionKey

public String getSessionKey()

setTimer

public void setTimer(commonj.timers.Timer t)

getTimer

public commonj.timers.Timer getTimer()

getParameters

public org.globus.mds.aggregator.types.AggregatorPollType getParameters()

getEntry

public AggregatorServiceGroupEntryResource getEntry()

timerExpired

public void timerExpired(commonj.timers.Timer timer)

Specified by:

timerExpired in interface commonj.timers.TimerListener