|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.globus.ogsa.client.managers.NotificationSinkManager
Class simplifying client side sink setup and notification subscription
Field Summary | |
static boolean |
CHILD_THREAD
|
static boolean |
MAIN_THREAD
|
protected java.util.Map |
properties
|
protected ServiceContainer |
serviceContainer
|
Constructor Summary | |
protected |
NotificationSinkManager()
|
Method Summary | |
java.lang.String |
addListener(java.util.Calendar timeout,
HandleType sourceHandle,
NotificationSinkCallback callback,
ExtensibilityType subscriptionExpression)
Subscribes to a set of service data entries of the specified service to receive notifications of the SDEs state change. |
java.lang.String |
addListener(javax.xml.namespace.QName[] serviceData,
java.util.Calendar timeout,
HandleType sourceHandle,
NotificationSinkCallback callback)
Subscribes to a set of service data entries of the specified service to receive notifications of the SDEs state change. |
java.lang.String |
addListener(javax.xml.namespace.QName[] serviceData,
java.util.Calendar timeout,
HandleType sourceHandle,
NotificationSinkCallback callback,
ExtensibilityType subscriptionExpression)
Deprecated. Use addListener() instead. |
java.lang.String |
addListener(javax.xml.namespace.QName serviceData,
java.util.Calendar timeout,
HandleType sourceHandle,
NotificationSinkCallback callback)
Subscribes to a service data entry of the specified service to receive notifications of the SDE state change. |
java.lang.String |
addListener(java.lang.String serviceData,
java.util.Calendar timeout,
HandleType sourceHandle,
NotificationSinkCallback callback)
Subscribes to a service data entry of the specified service to receive notifications of the SDE state change. |
java.lang.String |
addSink(NotificationSinkCallback callback)
|
java.lang.String |
addSink(NotificationSinkCallback callback,
java.lang.Object id)
|
java.util.Calendar |
getDefaultSubscriptionTimeout()
Returns default subscription timeout. |
static NotificationSinkManager |
getInstance(java.lang.String type)
|
static NotificationSinkManager |
getManager()
|
static java.lang.String |
getSinkID(java.net.URL url,
NotificationSinkCallback callback,
java.lang.Object obj)
|
NotificationSubscription |
getSubscriptionService(java.lang.String subscriptionID)
|
protected java.lang.String |
getWsdl()
|
void |
init(java.util.Map properties)
|
boolean |
isListening()
|
void |
removeListener(java.lang.String subscriptionID)
Unsubscribes a notification sink. |
void |
removeSink(java.lang.String sink)
|
protected void |
setCallbackEndpoint(NotificationSinkCallback callback)
|
protected void |
setCallbackHandle(NotificationSinkCallback callback)
|
protected void |
setProperties(javax.xml.rpc.Stub stub)
|
void |
setService(org.apache.axis.client.Service service)
|
void |
startListening()
|
void |
startListening(boolean isMainThread)
|
void |
stopListening()
|
void |
unregisterListener(java.lang.String subscriptionID)
Removes the listener from the subscription map. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
public static final boolean MAIN_THREAD
public static final boolean CHILD_THREAD
protected ServiceContainer serviceContainer
protected java.util.Map properties
Constructor Detail |
protected NotificationSinkManager()
Method Detail |
public static NotificationSinkManager getManager()
public static NotificationSinkManager getInstance(java.lang.String type)
public void init(java.util.Map properties)
public void setService(org.apache.axis.client.Service service)
protected java.lang.String getWsdl()
protected void setCallbackEndpoint(NotificationSinkCallback callback)
protected void setCallbackHandle(NotificationSinkCallback callback)
public java.lang.String addSink(NotificationSinkCallback callback) throws GridServiceException
GridServiceException
public java.lang.String addSink(NotificationSinkCallback callback, java.lang.Object id) throws GridServiceException
GridServiceException
public void removeSink(java.lang.String sink) throws GridServiceException
GridServiceException
protected void setProperties(javax.xml.rpc.Stub stub)
public static java.lang.String getSinkID(java.net.URL url, NotificationSinkCallback callback, java.lang.Object obj)
public NotificationSubscription getSubscriptionService(java.lang.String subscriptionID) throws FaultType, GridServiceException
FaultType
GridServiceException
public java.util.Calendar getDefaultSubscriptionTimeout()
public java.lang.String addListener(java.lang.String serviceData, java.util.Calendar timeout, HandleType sourceHandle, NotificationSinkCallback callback) throws java.rmi.RemoteException, GridServiceException
serviceData
- the service data name to subscribe to.
The service data name is a QName
with an empty namespace
and local name set to the specified service data name.timeout
- the timeout of the subscription. If null, timeout
returned by getDefaultSubscriptionTimeout()
is used.sourceHandle
- the GSH of the service to subscribe to.callback
- the notification sink.
java.rmi.RemoteException
GridServiceException
public java.lang.String addListener(javax.xml.namespace.QName serviceData, java.util.Calendar timeout, HandleType sourceHandle, NotificationSinkCallback callback) throws java.rmi.RemoteException, GridServiceException
serviceData
- the service data name to subscribe to.timeout
- the timeout of the subscription. If null, timeout
returned by getDefaultSubscriptionTimeout()
is used.sourceHandle
- the GSH of the service to subscribe to.callback
- the notification sink.
java.rmi.RemoteException
GridServiceException
public java.lang.String addListener(javax.xml.namespace.QName[] serviceData, java.util.Calendar timeout, HandleType sourceHandle, NotificationSinkCallback callback) throws java.rmi.RemoteException, GridServiceException
serviceData
- a set of service data names to subscribe to.timeout
- the timeout of the subscription. If null, timeout
returned by getDefaultSubscriptionTimeout()
is used.sourceHandle
- the GSH of the service to subscribe to.callback
- the notification sink.
java.rmi.RemoteException
GridServiceException
public java.lang.String addListener(javax.xml.namespace.QName[] serviceData, java.util.Calendar timeout, HandleType sourceHandle, NotificationSinkCallback callback, ExtensibilityType subscriptionExpression) throws java.rmi.RemoteException, GridServiceException
addListener()
instead.
java.rmi.RemoteException
GridServiceException
public java.lang.String addListener(java.util.Calendar timeout, HandleType sourceHandle, NotificationSinkCallback callback, ExtensibilityType subscriptionExpression) throws java.rmi.RemoteException, GridServiceException
timeout
- the timeout of the subscription. If null, timeout
returned by getDefaultSubscriptionTimeout()
is used.sourceHandle
- the GSH of the service to subscribe to.callback
- the notification sink.subscriptionExpression
- the subscription type to perform.
java.rmi.RemoteException
GridServiceException
public void removeListener(java.lang.String subscriptionID) throws java.rmi.RemoteException, GridServiceException
subscriptionID
- the id of the subscription to unsubscribe.
java.rmi.RemoteException
GridServiceException
public void unregisterListener(java.lang.String subscriptionID)
public void startListening(boolean isMainThread) throws GridServiceException
GridServiceException
public void startListening() throws GridServiceException
GridServiceException
public void stopListening() throws GridServiceException
GridServiceException
public boolean isListening()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |