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

java.lang.Object
  org.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