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

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

All Implemented Interfaces:

MaxIntervalTimerCallback, MinIntervalTimerCallback, QueryEvaluator, RegisterSubscriptionMessageReceiver, ServiceDataChangeMessageReceiver, UnregisterSubscriptionMessageReceiver

public class JMSServiceDataNameQueryEvaluator

extends JMSQueryEvaluator

implements MinIntervalTimerCallback, MaxIntervalTimerCallback

The JMSServiceDataNameQueryEvaluator class This class is used to query the SubscriptionExpression defined by the SubscriptionExpressionType -- SubscribeByServiceDataName

Field Summary

Fields inherited from class org.globus.ogsa.impl.core.notification.framework.jms.JMSQueryEvaluator

theSubscriptionCriteriaMap

Constructor Summary

JMSServiceDataNameQueryEvaluator(java.lang.String aSubscriptionExpressionType)
The ServiceDataChange subscriber

Method Summary

boolean	evaluateCriteria(java.lang.String aCriteria, java.lang.String aSubscriptionId) The evaluateCriteria Method This mehtod evaluates to see if the message has to be sent to the sink.
void	maxIntervalTimeElapsed(java.lang.String aSubscriptionId) Method maxIntervalGateOpen.
void	minIntervalGateOpen(java.lang.String aSubscriptionId) The min interval timer poped.
void	receiveRegisterSubscriptionMessage(Message aMessage) The receiveRegisterSubscriotionMessage method.
void	receiveServiceDataChangeMessage(Message aMessage) The receiveServiceDataChangeMessage method.
void	receiveUnregisterSubscriptionMessage(Message aMessage) The receiveUnregisterSubscriptionMessage method.
void	unregisterSubscription(java.lang.String subscriptionId) The unregisterSubscription method.

Methods inherited from class org.globus.ogsa.impl.core.notification.framework.jms.JMSQueryEvaluator

formatNotifyMessage, getJMSAdapter, getSubscriptionInfo, publishNotifyMessage, publishRefreshServiceDataMessage, registerSubscription

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSServiceDataNameQueryEvaluator

public JMSServiceDataNameQueryEvaluator(java.lang.String aSubscriptionExpressionType)
                                 throws java.lang.Exception

The ServiceDataChange subscriber

Throws:

java.lang.Exception - if the class can not be created

Method Detail

evaluateCriteria

public boolean evaluateCriteria(java.lang.String aCriteria,
                                java.lang.String aSubscriptionId)

The evaluateCriteria Method This mehtod evaluates to see if the message has to be sent to the sink. For ServiceDataNameSubscriptionExpressionType, this method will always return true.

Specified by:

evaluateCriteria in interface QueryEvaluator

Parameters:

aCriteria - - The subscription expression to be evaluated

aSubscriptionId - - the SubscriptionID.

Returns:

boolean --true, if message is to be sent to the sink --false, if message is not to be sent to the sink

receiveServiceDataChangeMessage

public void receiveServiceDataChangeMessage(Message aMessage)

The receiveServiceDataChangeMessage method. This method is executed when there is a servide data change notification

Specified by:

receiveServiceDataChangeMessage in interface ServiceDataChangeMessageReceiver

Specified by:

receiveServiceDataChangeMessage in class JMSQueryEvaluator

Parameters:

aMessage - - The service data change message.

receiveRegisterSubscriptionMessage

public void receiveRegisterSubscriptionMessage(Message aMessage)

The receiveRegisterSubscriotionMessage method. This method is executed when there is a message to the Register Subscription topic.

Specified by:

receiveRegisterSubscriptionMessage in interface RegisterSubscriptionMessageReceiver

Specified by:

receiveRegisterSubscriptionMessage in class JMSQueryEvaluator

Parameters:

aMessage - - The register subscription message.

receiveUnregisterSubscriptionMessage

public void receiveUnregisterSubscriptionMessage(Message aMessage)

The receiveUnregisterSubscriptionMessage method. This method is executed when there is a message to the Unregister Subscription topic.

Specified by:

receiveUnregisterSubscriptionMessage in interface UnregisterSubscriptionMessageReceiver

Specified by:

receiveUnregisterSubscriptionMessage in class JMSQueryEvaluator

Parameters:

aMessage - - The unregister subscription message.

unregisterSubscription

public void unregisterSubscription(java.lang.String subscriptionId)

Description copied from class: JMSQueryEvaluator

The unregisterSubscription method. Pull out the subscription id from the JMS unregister message, and remove the entry of this susbcription id from the hash map.

Overrides:

unregisterSubscription in class JMSQueryEvaluator

Parameters:

subscriptionId - - The subscriptionID to be removed.

minIntervalGateOpen

public void minIntervalGateOpen(java.lang.String aSubscriptionId)

The min interval timer poped. Set the flag in the subscription info to indicate such.

Specified by:

minIntervalGateOpen in interface MinIntervalTimerCallback

maxIntervalTimeElapsed

public void maxIntervalTimeElapsed(java.lang.String aSubscriptionId)

Method maxIntervalGateOpen.

Specified by:

maxIntervalTimeElapsed in interface MaxIntervalTimerCallback