org.globus.wsrf.impl.notification
Class SimpleSubscription

java.lang.Object
  org.globus.wsrf.impl.notification.SimpleSubscription

All Implemented Interfaces:

LocalInvocationEnabledSubscription, RemoveCallback, Resource, ResourceIdentifier, ResourceLifetime, ResourceProperties, SecureResource, java.io.Serializable, Subscription

Direct Known Subclasses:

PersistentSubscription

public class SimpleSubscription

extends java.lang.Object

implements LocalInvocationEnabledSubscription, ResourceProperties, ResourceIdentifier, ResourceLifetime, RemoveCallback, SecureResource, java.io.Serializable

Simple in-memory implementation of a subscription resource

See Also:

Serialized Form

Field Summary

protected NotifyCallback	callback
protected org.apache.axis.message.addressing.EndpointReferenceType	consumerReference
protected java.util.Calendar	creationTime
protected java.lang.String	id
protected boolean	isPaused
(package private) static org.apache.commons.logging.Log	logger
protected java.lang.Object	policy
protected QueryExpressionType	precondition
protected java.lang.String	producerHomeLocation
protected ResourceKey	producerKey
protected org.apache.axis.message.addressing.EndpointReferenceType	producerReference
private ResourcePropertySet	propertySet
protected ResourceSecurityDescriptor	resourceSecurityDescriptor
static javax.xml.namespace.QName	RP_SET
protected ClientSecurityDescriptor	securityDescriptor
protected QueryExpressionType	selector
protected java.util.Calendar	terminationTime
protected TopicExpressionType	topicExpression
protected boolean	useNotify
private static org.apache.axis.components.uuid.UUIDGen	uuidGen

Constructor Summary

SimpleSubscription()

SimpleSubscription(org.apache.axis.message.addressing.EndpointReferenceType consumerReference, org.apache.axis.message.addressing.EndpointReferenceType producerReference, java.util.Calendar initialTerminationTime, java.lang.Object policy, QueryExpressionType precondition, QueryExpressionType selector, ResourceKey producerKey, java.lang.String producerHomeLocation, TopicExpressionType topicExpression, boolean isPaused, boolean useNotify, ClientSecurityDescriptor notificationSecurityDescriptor, ResourceSecurityDescriptor resourceSecurityDescriptor)
Construct a new subscription resource.

SimpleSubscription(org.apache.axis.message.addressing.EndpointReferenceType consumerReference, org.apache.axis.message.addressing.EndpointReferenceType producerReference, java.util.Calendar initialTerminationTime, java.lang.Object policy, QueryExpressionType precondition, QueryExpressionType selector, ResourceKey producerKey, java.lang.String producerHomeLocation, TopicExpressionType topicExpression, boolean isPaused, boolean useNotify, ClientSecurityDescriptor notificationSecurityDescriptor, ResourceSecurityDescriptor resourceSecurityDescriptor, NotifyCallback callback)
Construct a new subscription resource.

Method Summary

NotifyCallback	getCallback() Get the object that implements NotifyCallback If any.
org.apache.axis.message.addressing.EndpointReferenceType	getConsumerReference() Get the consumer endpoint reference associated with this subscription
java.util.Calendar	getCreationTime() Get the time at which the resource was created.
java.util.Calendar	getCurrentTime() Get the current time
java.lang.Object	getID() Returns the unique id of the resource.
QueryExpressionType	getPrecondition() Get the precondition associated with this subscription
org.apache.axis.message.addressing.EndpointReferenceType	getProducerReference() Get the producer endpoint reference associated with this subscription
java.lang.Object	getResource() Get the producing resource
ResourcePropertySet	getResourcePropertySet() Returns ResourcePropertySet.
ResourceSecurityDescriptor	getSecurityDescriptor() Method to retrieve the security descriptor for this resource.
ClientSecurityDescriptor	getSecurityProperties() Get security properties that determine security for the notification call.
QueryExpressionType	getSelector() Get the selector expression associated with this subscription
java.lang.Object	getSubscriptionPolicy() Get the policy associated with this subscription
java.util.Calendar	getTerminationTime() Get the termination time
TopicExpressionType	getTopicExpression() Get the topic expression associated with this subscription
boolean	getUseNotify() Wrap notification messages in the notify element?
boolean	isPaused() Is the subscription paused?
void	pause() Pause the subscription
void	remove() Notifies that the resource was removed.
private boolean	removeListener(java.util.Collection topics)
void	resume() Resume the subscription
void	setTerminationTime(java.util.Calendar time) Set the termination time

Methods inherited from class java.lang.Object

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

Field Detail

logger

static org.apache.commons.logging.Log logger

RP_SET

public static final javax.xml.namespace.QName RP_SET

consumerReference

protected org.apache.axis.message.addressing.EndpointReferenceType consumerReference

producerReference

protected org.apache.axis.message.addressing.EndpointReferenceType producerReference

policy

protected java.lang.Object policy

precondition

protected QueryExpressionType precondition

selector

protected QueryExpressionType selector

producerKey

protected ResourceKey producerKey

producerHomeLocation

protected java.lang.String producerHomeLocation

topicExpression

protected TopicExpressionType topicExpression

isPaused

protected boolean isPaused

useNotify

protected boolean useNotify

terminationTime

protected java.util.Calendar terminationTime

creationTime

protected java.util.Calendar creationTime

securityDescriptor

protected ClientSecurityDescriptor securityDescriptor

id

protected java.lang.String id

resourceSecurityDescriptor

protected ResourceSecurityDescriptor resourceSecurityDescriptor

callback

protected NotifyCallback callback

propertySet

private transient ResourcePropertySet propertySet

uuidGen

private static final org.apache.axis.components.uuid.UUIDGen uuidGen

Constructor Detail

SimpleSubscription

public SimpleSubscription()

SimpleSubscription

public SimpleSubscription(org.apache.axis.message.addressing.EndpointReferenceType consumerReference,
                          org.apache.axis.message.addressing.EndpointReferenceType producerReference,
                          java.util.Calendar initialTerminationTime,
                          java.lang.Object policy,
                          QueryExpressionType precondition,
                          QueryExpressionType selector,
                          ResourceKey producerKey,
                          java.lang.String producerHomeLocation,
                          TopicExpressionType topicExpression,
                          boolean isPaused,
                          boolean useNotify,
                          ClientSecurityDescriptor notificationSecurityDescriptor,
                          ResourceSecurityDescriptor resourceSecurityDescriptor)

Construct a new subscription resource.

Parameters:

consumerReference - The WS-Addressing endpoint reference of the consumer

producerReference - The WS-Addressing endpoint reference of the producer

initialTerminationTime - The initial termination time of this resource

policy - The subscription policy

precondition - The precondition

selector - The selector

producerKey - The key of the producer resource

producerHomeLocation - The JNDI location of the home of the producer resource

topicExpression - The topic expression for this subscription

isPaused - The initial pause/resume state

useNotify - Whether to use raw notifications or not.

notificationSecurityDescriptor - Security settings for notify

resourceSecurityDescriptor - Security settings for this subscription resource

SimpleSubscription

public SimpleSubscription(org.apache.axis.message.addressing.EndpointReferenceType consumerReference,
                          org.apache.axis.message.addressing.EndpointReferenceType producerReference,
                          java.util.Calendar initialTerminationTime,
                          java.lang.Object policy,
                          QueryExpressionType precondition,
                          QueryExpressionType selector,
                          ResourceKey producerKey,
                          java.lang.String producerHomeLocation,
                          TopicExpressionType topicExpression,
                          boolean isPaused,
                          boolean useNotify,
                          ClientSecurityDescriptor notificationSecurityDescriptor,
                          ResourceSecurityDescriptor resourceSecurityDescriptor,
                          NotifyCallback callback)

Construct a new subscription resource.

Parameters:

consumerReference - The WS-Addressing endpoint reference of the consumer

producerReference - The WS-Addressing endpoint reference of the producer

initialTerminationTime - The initial termination time of this resource

policy - The subscription policy

precondition - The precondition

selector - The selector

producerKey - The key of the producer resource

producerHomeLocation - The JNDI location of the home of the producer resource

topicExpression - The topic expression for this subscription

isPaused - The initial pause/resume state

useNotify - Whether to use raw notifications or not.

notificationSecurityDescriptor - Security settings for notify

resourceSecurityDescriptor - Security settings for this subscription resource

Method Detail

getResourcePropertySet

public ResourcePropertySet getResourcePropertySet()

Description copied from interface: ResourceProperties

Returns ResourcePropertySet.

Specified by:

getResourcePropertySet in interface ResourceProperties

Returns:

ResourcePropertySet.

setTerminationTime

public void setTerminationTime(java.util.Calendar time)

Description copied from interface: ResourceLifetime

Set the termination time

Specified by:

setTerminationTime in interface ResourceLifetime

Parameters:

time - The termination time to set

getTerminationTime

public java.util.Calendar getTerminationTime()

Description copied from interface: ResourceLifetime

Get the termination time

Specified by:

getTerminationTime in interface ResourceLifetime

Returns:

The termination time

getCurrentTime

public java.util.Calendar getCurrentTime()

Description copied from interface: ResourceLifetime

Get the current time

Specified by:

getCurrentTime in interface ResourceLifetime

Returns:

The current time

getCreationTime

public java.util.Calendar getCreationTime()

Description copied from interface: Subscription

Get the time at which the resource was created.

Specified by:

getCreationTime in interface Subscription

Returns:

The creation time

getConsumerReference

public org.apache.axis.message.addressing.EndpointReferenceType getConsumerReference()

Description copied from interface: Subscription

Get the consumer endpoint reference associated with this subscription

Specified by:

getConsumerReference in interface Subscription

Returns:

The consumer endpoint reference

getSubscriptionPolicy

public java.lang.Object getSubscriptionPolicy()

Description copied from interface: Subscription

Get the policy associated with this subscription

Specified by:

getSubscriptionPolicy in interface Subscription

Returns:

The policy. May be null if no policy was specified in the subscription.

getPrecondition

public QueryExpressionType getPrecondition()

Description copied from interface: Subscription

Get the precondition associated with this subscription

Specified by:

getPrecondition in interface Subscription

Returns:

The precondition. May be null if no precondition was specified in the subscription.

getProducerReference

public org.apache.axis.message.addressing.EndpointReferenceType getProducerReference()

Description copied from interface: Subscription

Get the producer endpoint reference associated with this subscription

Specified by:

getProducerReference in interface Subscription

Returns:

The producer endpoint reference

getResource

public java.lang.Object getResource()
                             throws java.lang.Exception

Description copied from interface: Subscription

Get the producing resource

Specified by:

getResource in interface Subscription

Returns:

The producing resource

Throws:

java.lang.Exception

getSelector

public QueryExpressionType getSelector()

Description copied from interface: Subscription

Get the selector expression associated with this subscription

Specified by:

getSelector in interface Subscription

Returns:

The selector. May be null if no selector was specified in the subscription.

getTopicExpression

public TopicExpressionType getTopicExpression()

Description copied from interface: Subscription

Get the topic expression associated with this subscription

Specified by:

getTopicExpression in interface Subscription

Returns:

The topic expression

isPaused

public boolean isPaused()

Description copied from interface: Subscription

Is the subscription paused?

Specified by:

isPaused in interface Subscription

Returns:

True if the subscription is paused, false if not.

pause

public void pause()
           throws java.lang.Exception

Description copied from interface: Subscription

Pause the subscription

Specified by:

pause in interface Subscription

Throws:

java.lang.Exception

resume

public void resume()
            throws java.lang.Exception

Description copied from interface: Subscription

Resume the subscription

Specified by:

resume in interface Subscription

Throws:

java.lang.Exception

getUseNotify

public boolean getUseNotify()

Description copied from interface: Subscription

Wrap notification messages in the notify element?

Specified by:

getUseNotify in interface Subscription

Returns:

True (default) if notify should be used, false if not.

getSecurityProperties

public ClientSecurityDescriptor getSecurityProperties()

Description copied from interface: Subscription

Get security properties that determine security for the notification call. If any. Returns null for insecure subcriptions

Specified by:

getSecurityProperties in interface Subscription

Returns:

map of security properties.

getCallback

public NotifyCallback getCallback()

Description copied from interface: LocalInvocationEnabledSubscription

Get the object that implements NotifyCallback If any. Returns null for insecure subcriptions

Specified by:

getCallback in interface LocalInvocationEnabledSubscription

Returns:

callback

getID

public java.lang.Object getID()

Description copied from interface: ResourceIdentifier

Returns the unique id of the resource. In most cases this value should match value returned by ResoureKey.getValue().

Specified by:

getID in interface ResourceIdentifier

Returns:

the id of the resource.

remove

public void remove()
            throws ResourceException

Description copied from interface: RemoveCallback

Notifies that the resource was removed. This function must not be called directly on the resource object. Only ResourceHome.remove() is allowed to call that method during the remove operation.

Specified by:

remove in interface RemoveCallback

Throws:

ResourceException - if the remove operation fails.

removeListener

private boolean removeListener(java.util.Collection topics)

getSecurityDescriptor

public ResourceSecurityDescriptor getSecurityDescriptor()

Description copied from interface: SecureResource

Method to retrieve the security descriptor for this resource. If the descriptor does not have Subject and GridMap set, then it is recommended that ResourceSecurityConfig be used initialize the descriptor object. If the initialized is set to true, in the returned descriptor, then no initialization is done.

Specified by:

getSecurityDescriptor in interface SecureResource

Returns:

resource security descriptor for the resource. Can be null.