org.globus.wsrf.impl.notification
Class PersistentSubscription

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

All Implemented Interfaces:

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

public class PersistentSubscription

extends SimpleSubscription

implements PersistenceCallback

See Also:

Serialized Form

Field Summary

private static java.lang.String	FILE_SUFFIX
private static org.globus.util.I18n	i18n
private FilePersistenceHelper	persistenceHelper

Fields inherited from class org.globus.wsrf.impl.notification.SimpleSubscription

consumerReference, creationTime, id, isPaused, logger, policy, precondition, producerHomeLocation, producerKey, producerReference, resourceSecurityDescriptor, RP_SET, securityDescriptor, selector, terminationTime, topicExpression, useNotify

Constructor Summary

PersistentSubscription()

PersistentSubscription(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)

Method Summary

private java.io.File	getKeyAsFile(java.lang.Object key)
protected FilePersistenceHelper	getPersistenceHelper()
void	load(ResourceKey key) Loads the resource state.
void	pause() Pause the subscription
void	remove() Notifies that the resource was removed.
void	resume() Resume the subscription
void	setTerminationTime(java.util.Calendar time) Set the termination time
void	store() Saves the resource state.

Methods inherited from class org.globus.wsrf.impl.notification.SimpleSubscription

getConsumerReference, getCreationTime, getCurrentTime, getID, getPrecondition, getProducerReference, getResource, getResourcePropertySet, getSecurityDescriptor, getSecurityProperties, getSelector, getSubscriptionPolicy, getTerminationTime, getTopicExpression, getUseNotify, isPaused

Methods inherited from class java.lang.Object

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

Field Detail

i18n

private static org.globus.util.I18n i18n

persistenceHelper

private transient FilePersistenceHelper persistenceHelper

FILE_SUFFIX

private static final java.lang.String FILE_SUFFIX

See Also:

Constant Field Values

Constructor Detail

PersistentSubscription

public PersistentSubscription()

PersistentSubscription

public PersistentSubscription(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)

Method Detail

load

public void load(ResourceKey key)
          throws ResourceException,
                 NoSuchResourceException,
                 InvalidResourceKeyException

Description copied from interface: PersistenceCallback

Loads the resource state.

Specified by:

load in interface PersistenceCallback

Throws:

NoSuchResourceException - if no resource state exists for the specified key.

InvalidResourceKeyException - if the resource key is invalid.

ResourceException - if the load operation fails for any other reason.

store

public void store()
           throws ResourceException

Description copied from interface: PersistenceCallback

Saves the resource state.

Specified by:

store in interface PersistenceCallback

Throws:

ResourceException - if the store operation fails.

getKeyAsFile

private java.io.File getKeyAsFile(java.lang.Object key)
                           throws InvalidResourceKeyException

Throws:

InvalidResourceKeyException

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

Overrides:

remove in class SimpleSubscription

Throws:

ResourceException

getPersistenceHelper

protected FilePersistenceHelper getPersistenceHelper()

setTerminationTime

public void setTerminationTime(java.util.Calendar time)

Description copied from interface: ResourceLifetime

Set the termination time

Specified by:

setTerminationTime in interface ResourceLifetime

Overrides:

setTerminationTime in class SimpleSubscription

pause

public void pause()
           throws java.lang.Exception

Description copied from interface: Subscription

Pause the subscription

Specified by:

pause in interface Subscription

Overrides:

pause in class SimpleSubscription

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

Overrides:

resume in class SimpleSubscription

Throws:

java.lang.Exception