|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.globus.ogsa.impl.base.aggregator.SubscriptionAggregationSource
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 |
public SubscriptionAggregationSource()
Method Detail |
public void initialize(org.globus.ogsa.GridServiceBase serviceBase) throws org.globus.ogsa.GridServiceException
DataAggregationSource
initialize
in interface DataAggregationSource
serviceBase
- An implmentation may or may not register its instance
using setProperty() on the serviceBase parameter.
org.globus.ogsa.GridServiceException
public void terminate()
DataAggregationSource
terminate
in interface DataAggregationSource
public java.lang.Object getSessionContext(java.lang.String sessionID)
DataAggregationSource
getSessionContext
in interface DataAggregationSource
sessionID
- The session ID of the aggregation relationship.
public void setSessionContext(java.lang.String sessionID, java.lang.Object context)
DataAggregationSource
setSessionContext
in interface DataAggregationSource
sessionID
- The session ID that is to be associated with the context.context
- The context to associate.public boolean isValidSession(java.lang.String sessionID)
DataAggregationSource
isValidSession
in interface DataAggregationSource
public java.lang.String getSessionID(java.lang.Object context) throws java.lang.Exception
DataAggregationSource
getSessionID
in interface DataAggregationSource
java.lang.Exception
public java.lang.String addDataAggregation(DataAggregationType dataAggregation) throws org.globus.ogsa.GridServiceException
DataAggregationSource
addDataAggregation
in interface DataAggregationSource
dataAggregation
- Implementation-specific parameters of the data to be
collected.
org.globus.ogsa.GridServiceException
public void removeDataAggregation(java.lang.String sessionID) throws org.globus.ogsa.GridServiceException
DataAggregationSource
removeDataAggregation
in interface DataAggregationSource
sessionID
- The session ID of the aggregation relationship to terminate.
org.globus.ogsa.GridServiceException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |