org.globus.ogsa.impl.core.notification.framework.jms
Class JMSStateDataListener

java.lang.Object
  org.globus.ogsa.impl.core.notification.framework.jms.JMSStateDataListener

All Implemented Interfaces:

RefreshServiceDataMessageReceiver, ServiceDataListener, UnregisterSubscriptionMessageReceiver

public class JMSStateDataListener

extends java.lang.Object

implements ServiceDataListener, UnregisterSubscriptionMessageReceiver, RefreshServiceDataMessageReceiver

The JMSStateDataListener class. This class is used to create and retrieve the listener of the ServiceData Set.

Constructor Summary

JMSStateDataListener()

Method Summary

ServiceDataListener	create(java.lang.String subscriptionID, java.lang.String expressionType) Abstract factory create.
QueryEngine	getQueryEngine()
ServiceDataSet	getServiceDataSet() The getDataNotifyInterface method.
ExtensibilityType	getSubscriptionExpression()
protected void	notifyStateDataChange(QName serviceDataName, java.lang.String[] messageData, boolean ack) The notifyStateSataChange method.
void	receiveRefreshServiceDataMessage(Message aMessage) TODO: Documentation was wrong.
void	receiveUnregisterSubscriptionMessage(Message aMessage) The receiveUnRegisterSubscriptionMessage method.
void	serviceDataChanged(ServiceData data, boolean ack) TODO: Handle acknowledgement
void	setQueryEngine(QueryEngine queryEngine) Set the QueryEngine for this listener.
void	setServiceDataSet(ServiceDataSet aSet) The setServiceDataSet method.
void	setSubscriptionExpression(ExtensibilityType subscriptionExpression)

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSStateDataListener

public JMSStateDataListener()

Method Detail

create

public ServiceDataListener create(java.lang.String subscriptionID,
                                  java.lang.String expressionType)
                           throws java.lang.Exception

Abstract factory create.

Parameters:

subscriptionID - - The subscriptionID of the subscription.

expressionType - - The subscription Expression Type.

Returns:

ServiceDataListener

Throws:

java.lang.Exception - if the adapter can not be obtained

setQueryEngine

public void setQueryEngine(QueryEngine queryEngine)

Set the QueryEngine for this listener.

getQueryEngine

public QueryEngine getQueryEngine()

setServiceDataSet

public void setServiceDataSet(ServiceDataSet aSet)

The setServiceDataSet method. This method sets the service data set

getServiceDataSet

public ServiceDataSet getServiceDataSet()

The getDataNotifyInterface method. This is the accessor for the DataNotifyInterface.

Returns:

theServiceDataSet

setSubscriptionExpression

public void setSubscriptionExpression(ExtensibilityType subscriptionExpression)

getSubscriptionExpression

public ExtensibilityType getSubscriptionExpression()

serviceDataChanged

public void serviceDataChanged(ServiceData data,
                               boolean ack)

TODO: Handle acknowledgement

Specified by:

serviceDataChanged in interface ServiceDataListener

Parameters:

data - service data element that has changed

ack - a hint whether the notifier expects notifications sent off as a result of this notificaiton to be acknowledged

notifyStateDataChange

protected void notifyStateDataChange(QName serviceDataName,
                                     java.lang.String[] messageData,
                                     boolean ack)

The notifyStateSataChange method. This method is used to notify if there is a change in the ServiceData.

receiveUnregisterSubscriptionMessage

public void receiveUnregisterSubscriptionMessage(Message aMessage)

The receiveUnRegisterSubscriptionMessage method. This method is executed when there is a message to the UnregisterSubscription topic.

Specified by:

receiveUnregisterSubscriptionMessage in interface UnregisterSubscriptionMessageReceiver

Parameters:

aMessage - - The Unregister Subscription message.

receiveRefreshServiceDataMessage

public void receiveRefreshServiceDataMessage(Message aMessage)

TODO: Documentation was wrong. What does this method actually do?

Specified by:

receiveRefreshServiceDataMessage in interface RefreshServiceDataMessageReceiver

Parameters:

aMessage - - The Message