org.globus.ogsa.impl.base.aggregator
Class SubscriptionAggregationSource

java.lang.Object
  extended byorg.globus.ogsa.impl.base.aggregator.SubscriptionAggregationSource
All Implemented Interfaces:
DataAggregationSource

public class SubscriptionAggregationSource
extends java.lang.Object
implements DataAggregationSource

DataAggregationSource implmentation which subscribes to and republishes aggregated SDEs as the same SDEs on the local service.


Constructor Summary
SubscriptionAggregationSource()
           
 
Method Summary
 java.lang.String addDataAggregation(DataAggregationType dataAggregation)
          Delegated call made by the DataAggregatorManager's addDataAggregation method to allow an underlying DataAggregationSource to establish an implementation specific data aggregation relationship with a target grid service.
 java.lang.Object getSessionContext(java.lang.String sessionID)
          Retrieve implementation-specific session context.
 java.lang.String getSessionID(java.lang.Object context)
          Get a sessionID from a given context.
 void initialize(org.globus.ogsa.GridServiceBase serviceBase)
          Called after the aggregator manager has initialized itself, to give the DataAggregationSource a chance to initialize necessary state.
 boolean isValidSession(java.lang.String sessionID)
          Determines if a specified sessionID is valid (active).
 void removeDataAggregation(java.lang.String sessionID)
          Terminates the data aggregation relationship represented by sessionID.
 void setSessionContext(java.lang.String sessionID, java.lang.Object context)
          Associate an implementation-specific session context with a sessionID.
 void terminate()
          Called when the aggregator manager has been asked to shut down, before the manager executes its own termination code.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SubscriptionAggregationSource

public SubscriptionAggregationSource()
Method Detail

initialize

public void initialize(org.globus.ogsa.GridServiceBase serviceBase)
                throws org.globus.ogsa.GridServiceException
Description copied from interface: DataAggregationSource
Called after the aggregator manager has initialized itself, to give the DataAggregationSource a chance to initialize necessary state.

Specified by:
initialize in interface DataAggregationSource
Parameters:
serviceBase - An implmentation may or may not register its instance using setProperty() on the serviceBase parameter.
Throws:
org.globus.ogsa.GridServiceException

terminate

public void terminate()
Description copied from interface: DataAggregationSource
Called when the aggregator manager has been asked to shut down, before the manager executes its own termination code.

Specified by:
terminate in interface DataAggregationSource

getSessionContext

public java.lang.Object getSessionContext(java.lang.String sessionID)
Description copied from interface: DataAggregationSource
Retrieve implementation-specific session context.

Specified by:
getSessionContext in interface DataAggregationSource
Parameters:
sessionID - The session ID of the aggregation relationship.
Returns:
A valid object, or NULL. The type of object returned is dependent on the underlying implementation.

setSessionContext

public void setSessionContext(java.lang.String sessionID,
                              java.lang.Object context)
Description copied from interface: DataAggregationSource
Associate an implementation-specific session context with a sessionID. Note that the underlying implementation may choose to not permit this action (or only permit it under certain conditions) and may instead throw an exception.

Specified by:
setSessionContext in interface DataAggregationSource
Parameters:
sessionID - The session ID that is to be associated with the context.
context - The context to associate.

isValidSession

public boolean isValidSession(java.lang.String sessionID)
Description copied from interface: DataAggregationSource
Determines if a specified sessionID is valid (active).

Specified by:
isValidSession in interface DataAggregationSource
Returns:
A boolean value indicating whether the specified sessionID is valid.

getSessionID

public java.lang.String getSessionID(java.lang.Object context)
                              throws java.lang.Exception
Description copied from interface: DataAggregationSource
Get a sessionID from a given context. Note that the underlying type of the context parameter is implementation specific.

Specified by:
getSessionID in interface DataAggregationSource
Returns:
A string representing the sessionID for the given context.
Throws:
java.lang.Exception

addDataAggregation

public java.lang.String addDataAggregation(DataAggregationType dataAggregation)
                                    throws org.globus.ogsa.GridServiceException
Description copied from interface: DataAggregationSource
Delegated call made by the DataAggregatorManager's addDataAggregation method to allow an underlying DataAggregationSource to establish an implementation specific data aggregation relationship with a target grid service.

Specified by:
addDataAggregation in interface DataAggregationSource
Parameters:
dataAggregation - Implementation-specific parameters of the data to be collected.
Returns:
A String object which must be guaranteed by the underlying implementation to be a unique token with respect to all other invocataions of the addDataAggregation method with the same parameters on the same DataAggregationSource instance.
Throws:
org.globus.ogsa.GridServiceException

removeDataAggregation

public void removeDataAggregation(java.lang.String sessionID)
                           throws org.globus.ogsa.GridServiceException
Description copied from interface: DataAggregationSource
Terminates the data aggregation relationship represented by sessionID.

Specified by:
removeDataAggregation in interface DataAggregationSource
Parameters:
sessionID - The session ID of the aggregation relationship to terminate.
Throws:
org.globus.ogsa.GridServiceException