|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.globus.ogsa.impl.ogsi.NotificationSourceProvider
Notification source implementation used to subscribe and notify a collection of external sinks
Field Summary | |
protected GridServiceBase |
base
|
protected FactoryProvider |
factoryProvider
|
Constructor Summary | |
NotificationSourceProvider()
|
Method Summary | |
void |
activate(GridContext context)
Called when a service becomes active after having been deactivated. |
java.lang.String |
addSubscription(ExtensibilityType subscriptionExpression,
HandleType handle)
|
java.lang.String |
addSubscription(javax.xml.namespace.QName[] sdeNames,
HandleType handle)
|
java.lang.String |
addSubscription(javax.xml.namespace.QName[] sdeNames,
HandleType handle,
java.lang.String subscriptionID)
|
java.lang.String |
addSubscription(javax.xml.namespace.QName[] sdeNames,
HandleType handle,
java.lang.String subscriptionID,
org.apache.axis.types.Duration minInterval)
|
java.lang.String |
addSubscription(javax.xml.namespace.QName subscriptionName,
HandleType handle,
java.lang.String subscriptionID)
|
void |
addTopic(javax.xml.namespace.QName topic,
javax.xml.namespace.QName messageType)
|
void |
addTopic(java.lang.String topic,
javax.xml.namespace.QName messageType)
|
void |
deactivate(GridContext context)
Called just before a service gets deactivated. |
protected java.lang.String |
getNotificationFactoryProperty(org.apache.axis.MessageContext ctx)
|
javax.xml.namespace.QName[] |
getOperations()
Called during initialization when the Grid service needs to find out what operations are supported by this provider. |
protected java.lang.Object |
getSDEValue(java.util.Map cache,
javax.xml.namespace.QName sdeName)
|
java.util.Collection |
getServiceDataValues(javax.xml.namespace.QName qname)
Gets service data values requested for a service data element qname. |
protected java.lang.String |
getSubscriptionID()
|
void |
initialize(GridServiceBase base)
Called when the operation provider is added to a grid service. |
void |
notify(javax.xml.namespace.QName topic,
java.lang.Object messageData)
|
void |
notify(javax.xml.namespace.QName topic,
java.lang.Object messageData,
java.util.Map properties)
|
void |
notify(javax.xml.namespace.QName topic,
java.lang.Object messageData,
java.util.Map properties,
boolean ack)
|
void |
notify(java.lang.String topic,
java.lang.Object messageData)
|
void |
notify(java.lang.String topic,
java.lang.Object messageData,
java.util.Map properties)
|
protected void |
notifySDE(javax.xml.namespace.QName sdeName,
java.util.Map properties,
boolean ack)
Sends out notifications. |
void |
notifyWithAck(javax.xml.namespace.QName topic,
java.lang.Object messageData)
|
void |
notifyWithAck(javax.xml.namespace.QName topic,
java.lang.Object messageData,
java.util.Map properties)
|
void |
notifyWithAck(java.lang.String topic,
java.lang.Object messageData)
|
void |
notifyWithAck(java.lang.String topic,
java.lang.Object messageData,
java.util.Map properties)
|
void |
postCreate(GridContext context)
Called when a service has been created and all of its configuration has been set up. |
void |
preCreate(GridServiceBase base)
Called when a service object is created. |
void |
preDestroy(GridContext context)
Called just before a service gets destroyed. |
void |
removeSubscription(java.lang.String id)
|
void |
serviceDataChanged(ServiceData data,
boolean ack)
notifies the listener that a service data element has changed |
void |
subscribe(ExtensibilityType subscriptionExpression,
LocatorType sink,
ExtendedDateTimeType expirationTime,
LocatorTypeHolder subscriptionInstanceLocator,
TerminationTimeTypeHolder currentTerminationTime)
|
java.util.Iterator |
subscriptionServiceIterator(GridContext ctx)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected GridServiceBase base
protected FactoryProvider factoryProvider
Constructor Detail |
public NotificationSourceProvider()
Method Detail |
public void preCreate(GridServiceBase base) throws GridServiceException
GridServiceCallback
preCreate
in interface GridServiceCallback
base
- the Grid service that is in the process of creating this
service object, or if this is a persistent Grid service it points to
the service to be created.
GridServiceException
- if the service should not be createdpublic void postCreate(GridContext context) throws GridServiceException
GridServiceCallback
postCreate
in interface GridServiceCallback
context
- state information currently associated with the service
that was created.
GridServiceException
- if the service creation should be abortedpublic void activate(GridContext context) throws GridServiceException
GridServiceCallback
activate
in interface GridServiceCallback
context
- state information currently associated with the service
GridServiceException
- if the service activation should be abortedpublic void deactivate(GridContext context) throws GridServiceException
GridServiceCallback
deactivate
in interface GridServiceCallback
context
- state information currently associated with the service
GridServiceException
- if the service deactivation failedpublic void preDestroy(GridContext context) throws GridServiceException
GridServiceCallback
preDestroy
in interface GridServiceCallback
context
- state information currently associated with the service
GridServiceException
- if the destruction failed (will be
reported to clients in the case of explicit destroy calls)public javax.xml.namespace.QName[] getOperations()
OperationProvider
getOperations
in interface OperationProvider
new QName[] {new QName("","*")}
, will result in all
incoming operations being redirected to this provider (apart from the
OGSI defined GridService interface operations provided by the
GridServiceBase implementation. Note that individual
operations in the OGSI namespace could still be overridded with this
approach, but not using the 'all namespaces and all operation' wildcard.
public void initialize(GridServiceBase base) throws GridServiceException
OperationProvider
initialize
in interface OperationProvider
base
- the service this provider is being associated with
GridServiceException
- if the initialization (and service creation
is to be aborted)public java.util.Collection getServiceDataValues(javax.xml.namespace.QName qname)
ServiceDataValueCallback
getServiceDataValues
in interface ServiceDataValueCallback
qname
- name of service data element (all values will be wrapped
inside of element tags with this qname)
protected java.lang.String getSubscriptionID()
public java.lang.String addSubscription(ExtensibilityType subscriptionExpression, HandleType handle) throws GridServiceException, TargetInvalidFaultType, ExtensibilityNotSupportedFaultType
addSubscription
in interface NotificationProvider
GridServiceException
TargetInvalidFaultType
ExtensibilityNotSupportedFaultType
public java.lang.String addSubscription(javax.xml.namespace.QName subscriptionName, HandleType handle, java.lang.String subscriptionID) throws TargetInvalidFaultType
addSubscription
in interface NotificationProvider
TargetInvalidFaultType
public java.lang.String addSubscription(javax.xml.namespace.QName[] sdeNames, HandleType handle) throws TargetInvalidFaultType
addSubscription
in interface NotificationProvider
TargetInvalidFaultType
public java.lang.String addSubscription(javax.xml.namespace.QName[] sdeNames, HandleType handle, java.lang.String subscriptionID) throws TargetInvalidFaultType
addSubscription
in interface NotificationProvider
TargetInvalidFaultType
public java.lang.String addSubscription(javax.xml.namespace.QName[] sdeNames, HandleType handle, java.lang.String subscriptionID, org.apache.axis.types.Duration minInterval) throws TargetInvalidFaultType
TargetInvalidFaultType
public void removeSubscription(java.lang.String id) throws TargetInvalidFaultType
removeSubscription
in interface NotificationProvider
TargetInvalidFaultType
public void serviceDataChanged(ServiceData data, boolean ack)
ServiceDataListener
serviceDataChanged
in interface ServiceDataListener
data
- service data element that has changedack
- a hint whether the notifier expects notifications
sent off as a result of this notificaiton to be acknowledgedprotected java.lang.Object getSDEValue(java.util.Map cache, javax.xml.namespace.QName sdeName) throws GridServiceException
GridServiceException
protected void notifySDE(javax.xml.namespace.QName sdeName, java.util.Map properties, boolean ack)
protected java.lang.String getNotificationFactoryProperty(org.apache.axis.MessageContext ctx)
public void subscribe(ExtensibilityType subscriptionExpression, LocatorType sink, ExtendedDateTimeType expirationTime, LocatorTypeHolder subscriptionInstanceLocator, TerminationTimeTypeHolder currentTerminationTime) throws java.rmi.RemoteException, FaultType, TargetInvalidFaultType, ExtensibilityNotSupportedFaultType, ExtensibilityTypeFaultType
java.rmi.RemoteException
FaultType
TargetInvalidFaultType
ExtensibilityNotSupportedFaultType
ExtensibilityTypeFaultType
public void addTopic(java.lang.String topic, javax.xml.namespace.QName messageType) throws TopicAlreadyExistsException, GridServiceException
addTopic
in interface NotificationProvider
TopicAlreadyExistsException
GridServiceException
public void addTopic(javax.xml.namespace.QName topic, javax.xml.namespace.QName messageType) throws TopicAlreadyExistsException, GridServiceException
addTopic
in interface NotificationProvider
TopicAlreadyExistsException
GridServiceException
public void notify(java.lang.String topic, java.lang.Object messageData)
notify
in interface NotificationProvider
public void notify(javax.xml.namespace.QName topic, java.lang.Object messageData)
notify
in interface NotificationProvider
public void notifyWithAck(java.lang.String topic, java.lang.Object messageData)
public void notifyWithAck(javax.xml.namespace.QName topic, java.lang.Object messageData)
public void notify(java.lang.String topic, java.lang.Object messageData, java.util.Map properties)
notify
in interface NotificationProvider
public void notify(javax.xml.namespace.QName topic, java.lang.Object messageData, java.util.Map properties)
notify
in interface NotificationProvider
public void notifyWithAck(javax.xml.namespace.QName topic, java.lang.Object messageData, java.util.Map properties)
public void notifyWithAck(java.lang.String topic, java.lang.Object messageData, java.util.Map properties)
public void notify(javax.xml.namespace.QName topic, java.lang.Object messageData, java.util.Map properties, boolean ack)
public java.util.Iterator subscriptionServiceIterator(GridContext ctx) throws GridServiceException
GridServiceException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |