|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
This interface handles session management for establishing data aggregation relationships between grid services. The exact data-interchange method is abstracted in order to provide an extensibility mechanism. For example, the underlying session may represented by an asynchronous notification channel (e.g. OGSA subscription), a synchronous polling mechanism (e.g. repeated FindServiceData queries) or some other mechanism, such as a command buffer or FIFO.
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. |
Method Detail |
public void initialize(org.globus.ogsa.GridServiceBase serviceBase) throws org.globus.ogsa.GridServiceException
serviceBase
- An implmentation may or may not register its instance
using setProperty() on the serviceBase parameter.
org.globus.ogsa.GridServiceException
public void terminate()
public java.lang.String addDataAggregation(DataAggregationType dataAggregation) throws org.globus.ogsa.GridServiceException
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
sessionID
- The session ID of the aggregation relationship to terminate.
org.globus.ogsa.GridServiceException
public java.lang.Object getSessionContext(java.lang.String sessionID)
sessionID
- The session ID of the aggregation relationship.
public void setSessionContext(java.lang.String sessionID, java.lang.Object context) throws java.lang.Exception
sessionID
- The session ID that is to be associated with the context.context
- The context to associate.
java.lang.Exception
public java.lang.String getSessionID(java.lang.Object context) throws java.lang.Exception
java.lang.Exception
public boolean isValidSession(java.lang.String sessionID) throws java.lang.Exception
java.lang.Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |