org.globus.ogsa.impl.base.providers.servicedata
Class ServiceDataProviderManager

java.lang.Object
  extended byorg.globus.ogsa.impl.base.providers.servicedata.ServiceDataProviderManager
All Implemented Interfaces:
org.globus.ogsa.OperationProvider, java.rmi.Remote, ServiceDataProviderDocumentCallback, ServiceDataProviderExecutionCallback, ServiceDataProviderExecutionPortType

public class ServiceDataProviderManager
extends java.lang.Object
implements ServiceDataProviderExecutionPortType, ServiceDataProviderExecutionCallback, ServiceDataProviderDocumentCallback, org.globus.ogsa.OperationProvider

Execution framework for Service Data Providers


Nested Class Summary
 class ServiceDataProviderManager.GarbageCollectionTask
           
 
Field Summary
static java.lang.String DEFAULT_NAMESPACE
           
static java.lang.String MANAGER_INSTANCE
           
 boolean periodicGC
           
 
Constructor Summary
ServiceDataProviderManager()
           
 
Method Summary
 boolean defaultProviderCallback(org.w3c.dom.Document doc, java.lang.Object context, java.lang.Integer providerState)
           
 ServiceDataProviderEnumType[] enumProviders(boolean rescanConfig)
          Iterates through an array of installed providers and creates a service data element representing the list, also returns the list as an array
 void executeProvider(ServiceDataProviderExecutionType newServiceData)
           
 void executeProvider(ServiceDataProviderExecutionType newServiceData, java.lang.Object callbackObj)
          Creates a new service data element whose value is the output of the specified service data provider and schedules it for repeated background execution via TimerTask.
 void exitStatus(ServiceDataProviderExecutionTask task)
           
 java.lang.Class[] getCallbackParamSig(java.lang.String methodName)
           
 java.lang.String getDefaultCallbackMethodName()
           
 java.lang.String getHandlerName(java.lang.String providerClass)
           
 javax.xml.namespace.QName[] getOperations()
           
 void initialize(org.globus.ogsa.GridServiceBase serviceBase)
           
 void terminateAll()
           
 boolean versionCheck(java.lang.String requestedVersion)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

DEFAULT_NAMESPACE

public static final java.lang.String DEFAULT_NAMESPACE
See Also:
Constant Field Values

MANAGER_INSTANCE

public static final java.lang.String MANAGER_INSTANCE
See Also:
Constant Field Values

periodicGC

public boolean periodicGC
Constructor Detail

ServiceDataProviderManager

public ServiceDataProviderManager()
Method Detail

getHandlerName

public java.lang.String getHandlerName(java.lang.String providerClass)

getOperations

public javax.xml.namespace.QName[] getOperations()
Specified by:
getOperations in interface org.globus.ogsa.OperationProvider

initialize

public void initialize(org.globus.ogsa.GridServiceBase serviceBase)
                throws org.globus.ogsa.GridServiceException
Specified by:
initialize in interface org.globus.ogsa.OperationProvider
Throws:
org.globus.ogsa.GridServiceException

versionCheck

public boolean versionCheck(java.lang.String requestedVersion)

enumProviders

public ServiceDataProviderEnumType[] enumProviders(boolean rescanConfig)
                                            throws java.rmi.RemoteException
Iterates through an array of installed providers and creates a service data element representing the list, also returns the list as an array

Specified by:
enumProviders in interface ServiceDataProviderExecutionPortType
Throws:
java.rmi.RemoteException

executeProvider

public void executeProvider(ServiceDataProviderExecutionType newServiceData,
                            java.lang.Object callbackObj)
                     throws java.rmi.RemoteException
Creates a new service data element whose value is the output of the specified service data provider and schedules it for repeated background execution via TimerTask. An optional callback object can be passed if the application wants implement a custom handler for the result data.

Throws:
java.rmi.RemoteException

executeProvider

public void executeProvider(ServiceDataProviderExecutionType newServiceData)
                     throws java.rmi.RemoteException
Specified by:
executeProvider in interface ServiceDataProviderExecutionPortType
Throws:
java.rmi.RemoteException

exitStatus

public void exitStatus(ServiceDataProviderExecutionTask task)
Specified by:
exitStatus in interface ServiceDataProviderExecutionCallback

defaultProviderCallback

public boolean defaultProviderCallback(org.w3c.dom.Document doc,
                                       java.lang.Object context,
                                       java.lang.Integer providerState)
                                throws java.lang.Exception
Throws:
java.lang.Exception

terminateAll

public void terminateAll()
                  throws java.lang.Exception
Throws:
java.lang.Exception

getDefaultCallbackMethodName

public java.lang.String getDefaultCallbackMethodName()
Specified by:
getDefaultCallbackMethodName in interface ServiceDataProviderDocumentCallback

getCallbackParamSig

public java.lang.Class[] getCallbackParamSig(java.lang.String methodName)
Specified by:
getCallbackParamSig in interface ServiceDataProviderDocumentCallback