org.globus.ogsa.impl.base.gram.rips
Class RIPSImpl

java.lang.Object
  org.globus.ogsa.impl.core.service.ServicePropertiesImpl
      org.globus.ogsa.impl.ogsi.GridServiceImpl
          org.globus.ogsa.impl.base.gram.rips.RIPSImpl

All Implemented Interfaces:

GridServiceBase, GridServiceCallback, ServiceDataProviderDocumentCallback, ServiceDataValueCallback, ServiceProperties

public class RIPSImpl

extends GridServiceImpl

implements ServiceDataProviderDocumentCallback

GRAM Resource Information Provider Service

Field Summary

static java.lang.String	RIPS_NS
static java.lang.String	RIPS_NS_MAPPING
static java.lang.String	RIPS_NS_PREFIX

Fields inherited from class org.globus.ogsa.impl.ogsi.GridServiceImpl

queryEngine, serviceData

Fields inherited from interface org.globus.ogsa.ServiceProperties

ACTIVATE_ON_STARTUP, ACTIVATION, BASE_CLASS_NAME, BOOTSTRAP, CONFIG_PATH, CONTAINS_REFERENCE, CREATION_EXTENSIBILITY, CREATION_EXTENSIBILITY_OUTPUT, CUSTOM_EXTENSIBILITY_DESERIALIZER, CUSTOM_EXTENSIBILITY_SERIALIZER, CUSTOM_MAPPING_REGISTERED, DEACTIVATED_PERSISTENT, DEACTIVATED_STATE, DEACTIVATED_TRANSIENT, DEACTIVATION, DESTROY_LISTENER, DESTRUCTION_SKELETON, DISABLE_FACTORY_REGISTRY, ENDPOINT, ENTRY_INSTANCE_CREATION, FACTORY, FACTORY_CALLBACK, FACTORY_HANDLE, FACTORY_PROVIDER, FACTORY_REGISTRY, GSR_DESCRIPTION, HANDLE, HANDLE_PORT, HANDLE_PROTOCOL, INSTANCE_CLASS, INSTANCE_DEACTIVATION, INSTANCE_GSR_DESCRIPTION, INSTANCE_LIFECYCLE, INSTANCE_PORT_TYPE, INSTANCE_PORT_TYPE_NS, INSTANCE_PREFIX, INSTANCE_REGISTRY, INSTANCE_SCHEMA_PATH, INSTANCE_WSDL, INTERFACE_CLASS_NAME, INVOCATION_ID, LAZY_CREATION, LIFECYCLE, LIFECYCLE_MONITOR, LIFECYCLE_MONITOR_CLASS, NAME, NOTIFICATION_ENGINE, NOTIFICATION_FACTORY, NOTIFICATION_SOURCE, OPERATION_PROVIDERS, PERSISTENT, PERSISTENT_PROPERTIES, PORT, PORT_TYPE, PORT_TYPE_NS, PRIMARY_KEY, PROTOCOL, QUERY_ENGINE, REDIRECT_RESOLVER, REGISTRY, RESOLVER_CACHE, ROUTER_HEADER, ROUTER_VIA, SCHEMA_LOCATION, SCHEMA_PATH, SERVICE_ACTIVATOR, SERVICE_DATA, SERVICE_DEPLOYMENT, SERVICE_GROUP_ENTRY, SERVICE_GROUP_PROVIDER, SERVICE_LOADER, SERVICE_NODE, SERVICE_PATH, SINK_ID, STARTUP_STATE, SWEEP_SERVICE_DATA, TIMEOUT, TIMESTAMP, TRANSIENT, TYPE, USER, WEBSTART_PANEL_NAME, WEBSTART_URL, WSDL

Constructor Summary

RIPSImpl()

Method Summary

ServiceDataProviderEnumType[]	enumProviders(boolean rescanConfig)
void	executeProvider(ServiceDataProviderExecutionType newServiceData)
java.lang.Class[]	getCallbackParamSig(java.lang.String methodName)
HandleType	getCurrentHandle()
java.lang.String	getDefaultCallbackMethodName()
boolean	jobDataHandler(org.w3c.dom.Document doc, java.lang.Object context, java.lang.Integer providerState) This routine handles the majority of the state management for the service.
void	postCreate(GridContext context) Called when a service has been created and all of its configuration has been set up.
void	preDestroy(GridContext context) Called just before a service gets destroyed.
void	subscribe(ExtensibilityType subscriptionExpression, LocatorType sink, ExtendedDateTimeType expirationTime, LocatorTypeHolder subscriptionInstanceLocator, TerminationTimeTypeHolder currentTerminationTime) Services may to subscribe to job elements where the intial state data might not exist yet, so the default behavior with RIPS will be to create an empty SDE as a placeholder, IFF there is no already existing SDE of the same name.

Methods inherited from class org.globus.ogsa.impl.ogsi.GridServiceImpl

activate, addOperationProvider, deactivate, destroy, findServiceData, getInstanceProperty, getOperationProvider, getQueryEngine, getServiceDataSet, getServiceDataValues, getServiceInterface, getTerminationTime, populateInstanceProperties, preCreate, removeOperationProvider, requestTerminationAfter, requestTerminationBefore, setDefaultTermination, setQueryEngine, setServiceData, setServiceDataSet

Methods inherited from class org.globus.ogsa.impl.core.service.ServicePropertiesImpl

flush, flush, getPersistentProperty, getProperty, keySet, setPersistentProperty, setProperty, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.globus.ogsa.ServiceProperties

flush, getPersistentProperty, getProperty, setPersistentProperty, setProperty

Field Detail

RIPS_NS

public static final java.lang.String RIPS_NS

See Also:

Constant Field Values

RIPS_NS_PREFIX

public static final java.lang.String RIPS_NS_PREFIX

See Also:

Constant Field Values

RIPS_NS_MAPPING

public static final java.lang.String RIPS_NS_MAPPING

See Also:

Constant Field Values

Constructor Detail

RIPSImpl

public RIPSImpl()

Method Detail

getCurrentHandle

public HandleType getCurrentHandle()

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

postCreate

public void postCreate(GridContext context)
                throws GridServiceException

Description copied from interface: GridServiceCallback

Called when a service has been created and all of its configuration has been set up.

Specified by:

postCreate in interface GridServiceCallback

Overrides:

postCreate in class GridServiceImpl

Throws:

GridServiceException

preDestroy

public void preDestroy(GridContext context)
                throws GridServiceException

Description copied from interface: GridServiceCallback

Called just before a service gets destroyed. After this call is made the framework removes all knowledge about the service, so it is a good place to clean up service resources. Note that this call can be triggered both by a client initiated destroy call, as well as a framework initiated softstate timeout.

Specified by:

preDestroy in interface GridServiceCallback

Overrides:

preDestroy in class GridServiceImpl

Throws:

GridServiceException

enumProviders

public ServiceDataProviderEnumType[] enumProviders(boolean rescanConfig)
                                            throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

executeProvider

public void executeProvider(ServiceDataProviderExecutionType newServiceData)
                     throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

subscribe

public void subscribe(ExtensibilityType subscriptionExpression,
                      LocatorType sink,
                      ExtendedDateTimeType expirationTime,
                      LocatorTypeHolder subscriptionInstanceLocator,
                      TerminationTimeTypeHolder currentTerminationTime)
               throws java.rmi.RemoteException,
                      FaultType,
                      TargetInvalidFaultType,
                      ExtensibilityNotSupportedFaultType,
                      ExtensibilityTypeFaultType

Services may to subscribe to job elements where the intial state data might not exist yet, so the default behavior with RIPS will be to create an empty SDE as a placeholder, IFF there is no already existing SDE of the same name.

Throws:

java.rmi.RemoteException

FaultType

TargetInvalidFaultType

ExtensibilityNotSupportedFaultType

ExtensibilityTypeFaultType

jobDataHandler

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

This routine handles the majority of the state management for the service.

Throws:

java.lang.Exception