Package org.globus.mds.aggregator.impl

Interface Summary

AggregatorConstants	Constants that may be useful in the context of the aggregator.
AggregatorServiceGroupEntryRemovedCallback	Service developers incorporating the Aggregator framework may implement this interface, specifying the implementing class as the "entryRemovedCallback" parameter in the AggregatorConfiguration JNDI bean of a service jndi-config.xml file.
AggregatorSink	This interface must be implemented by a plugin for the AggregatorSource component of the aggregator and is generally type-specific to the message data being processed.
AggregatorSource	The AggregatorSource interface handles session management for establishing data aggregation relationships between services using source-sink paradigms.

Class Summary

AggregatorConfiguration
AggregatorServiceGroupEntryHome	Looks up a service group entry.
AggregatorServiceGroupEntryResource	Implements an aggregating service group entry resource.
AggregatorServiceGroupHome
AggregatorServiceGroupResource	Implements an aggregating in-memory service group resource.
AggregatorUtils
ExecutionAggregatorSource	An AggregatorSource which generates data using synchronous poll-style execution of an administrator-configured script.
PollingAggregatorSource	An AggregatorSource which generates data using synchronous polling in a background thread.
QueryAggregatorSource	A PollingAggregatorSource that polls using WSRF resource property operations.
ServiceGroupEntryAggregatorSink	The ServiceGroupEntryAggregatorSink stores aggregate data as ServiceGroupEntry content.
SingletonAggregatorHome	This home provides a singleton home that creates a single resource based on JNDI parameter, configured in the same way as ResourceHomeImpl: resourceClass - configures the name of the resource class.
SubscriptionAggregatorSource	An AggregatorSource which generates data using asyncrhonous subscription-based messaging.

Exception Summary

AggregatorException	This exception is a generic superclass for aggregator runtime exceptions.
AggregatorParamTypeNotSupportedException
AggregatorSinkTypeNotSupportedException