com.ebmwebsourcing.wsstar.wsnb.services.impl.engines
Class SubscriptionManagerEngine

java.lang.Object
  com.ebmwebsourcing.wsstar.wsnb.services.impl.engines.SubscriptionManagerEngine

All Implemented Interfaces:

com.ebmwebsourcing.wsstar.wsnb.services.ISubscriptionManager

Direct Known Subclasses:

PausableSubscriptionManagerEngine

public class SubscriptionManagerEngine
extends java.lang.Object
implements com.ebmwebsourcing.wsstar.wsnb.services.ISubscriptionManager

Field Summary

protected java.util.logging.Logger	logger
protected com.ebmwebsourcing.wsstar.wsnb.services.transport.ITransporterForWsnbPublisher	notificationSender
protected WsnbPersistence	persistenceMgr
protected java.util.Map<java.lang.String,WsnSubscription>	subscriptions
protected java.lang.String	subscriptionsManagerEdp
protected javax.xml.namespace.QName	subscriptionsManagerInterface
protected javax.xml.namespace.QName	subscriptionsManagerService
protected java.lang.String	targetSubscriptionResourceUuid
protected java.util.Map<javax.xml.namespace.QName,java.util.List<java.lang.String>>	uuidsPerTopics

Constructor Summary

SubscriptionManagerEngine(java.util.logging.Logger logger)

SubscriptionManagerEngine(java.util.logging.Logger logger, WsnbPersistence persistenceMgr, com.ebmwebsourcing.wsstar.wsnb.services.transport.ITransporterForWsnbPublisher transporter)

Method Summary

com.ebmwebsourcing.wsstar.addressing.datatypes.api.abstraction.EndpointReferenceType	createAndStoreSubscriptionResource(java.lang.String subscriptionId, java.util.List<com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.TopicExpressionType> topics, com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.Subscribe payload)
com.ebmwebsourcing.wsstar.addressing.datatypes.api.abstraction.EndpointReferenceType	getConsumerEdpRefOfSubscription(java.lang.String subscriptionId)
com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.FilterType	getFilterOfSubscription(java.lang.String subscriptionId)
com.ebmwebsourcing.wsstar.wsnb.services.transport.ITransporterForWsnbPublisher	getNotificationSender()
com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.SubscriptionPolicyType	getPolicyOfSubscription(java.lang.String subscriptionId)
java.util.List<java.lang.String>	getStoredSubscriptionUuids()
com.ebmwebsourcing.wsstar.addressing.datatypes.api.abstraction.EndpointReferenceType	getSubscriptionRef(java.lang.String subscriptionId)
java.lang.String	getSubscriptionsManagerEdp()
javax.xml.namespace.QName	getSubscriptionsManagerInterface()
javax.xml.namespace.QName	getSubscriptionsManagerService()
java.util.Date	getTerminationTimeOfSubscription(java.lang.String subscriptionId)
java.util.List<com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.TopicExpressionType>	getTopicExpressionOfSubscription(java.lang.String subscriptionId)
java.util.List<java.lang.String>	lookForSubscriptionToTerminate(org.w3c.dom.Document topicSetAsDOM, TopicsManagerEngine wstopEngine) look for subscription which topics are no longer supported
java.util.List<java.lang.String>	removeAllSubscription()
void	removeExpiredSubscription(java.lang.String subscriptionId)
com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.RenewResponse	renew(com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.Renew payload)
void	restorePersistedSubscriptions(TopicsManagerEngine topicsMgr, org.w3c.dom.Document supportedTopicsAsDOM)
void	setNotificationSender(com.ebmwebsourcing.wsstar.wsnb.services.transport.ITransporterForWsnbPublisher notificationSender)
void	setSubscriptionsManagerEdp(java.lang.String subscriptionsMgrEdp)
void	setSubscriptionsManagerInterface(javax.xml.namespace.QName subscriptionsMgrInterface)
void	setSubscriptionsManagerService(javax.xml.namespace.QName subscriptionsMgrService)
void	setTargetSubscriptionResourceUuid(java.lang.String subscriptionUuid)
void	terminateSubscription(java.lang.String subscriptionUuid)
com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.UnsubscribeResponse	unsubscribe(com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.Unsubscribe payload)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected java.util.logging.Logger logger

subscriptions

protected java.util.Map<java.lang.String,WsnSubscription> subscriptions

uuidsPerTopics

protected java.util.Map<javax.xml.namespace.QName,java.util.List<java.lang.String>> uuidsPerTopics

persistenceMgr

protected WsnbPersistence persistenceMgr

subscriptionsManagerEdp

protected java.lang.String subscriptionsManagerEdp

subscriptionsManagerService

protected javax.xml.namespace.QName subscriptionsManagerService

subscriptionsManagerInterface

protected javax.xml.namespace.QName subscriptionsManagerInterface

targetSubscriptionResourceUuid

protected java.lang.String targetSubscriptionResourceUuid

notificationSender

protected com.ebmwebsourcing.wsstar.wsnb.services.transport.ITransporterForWsnbPublisher notificationSender

Constructor Detail

SubscriptionManagerEngine

public SubscriptionManagerEngine(java.util.logging.Logger logger,
                                 WsnbPersistence persistenceMgr,
                                 com.ebmwebsourcing.wsstar.wsnb.services.transport.ITransporterForWsnbPublisher transporter)

SubscriptionManagerEngine

public SubscriptionManagerEngine(java.util.logging.Logger logger)

Method Detail

getSubscriptionsManagerEdp

public java.lang.String getSubscriptionsManagerEdp()

Returns:

setSubscriptionsManagerEdp

public void setSubscriptionsManagerEdp(java.lang.String subscriptionsMgrEdp)

getSubscriptionsManagerService

public javax.xml.namespace.QName getSubscriptionsManagerService()

setSubscriptionsManagerService

public void setSubscriptionsManagerService(javax.xml.namespace.QName subscriptionsMgrService)

getSubscriptionsManagerInterface

public javax.xml.namespace.QName getSubscriptionsManagerInterface()

setSubscriptionsManagerInterface

public void setSubscriptionsManagerInterface(javax.xml.namespace.QName subscriptionsMgrInterface)

getStoredSubscriptionUuids

public java.util.List<java.lang.String> getStoredSubscriptionUuids()

setTargetSubscriptionResourceUuid

public void setTargetSubscriptionResourceUuid(java.lang.String subscriptionUuid)

getNotificationSender

public com.ebmwebsourcing.wsstar.wsnb.services.transport.ITransporterForWsnbPublisher getNotificationSender()

setNotificationSender

public void setNotificationSender(com.ebmwebsourcing.wsstar.wsnb.services.transport.ITransporterForWsnbPublisher notificationSender)

unsubscribe

public com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.UnsubscribeResponse unsubscribe(com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.Unsubscribe payload)
                                                                                                     throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException,
                                                                                                            com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault

Specified by:

unsubscribe in interface com.ebmwebsourcing.wsstar.wsnb.services.ISubscriptionManager

Throws:

com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault

renew

public com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.RenewResponse renew(com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.Renew payload)
                                                                                         throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException,
                                                                                                com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault

Specified by:

renew in interface com.ebmwebsourcing.wsstar.wsnb.services.ISubscriptionManager

Throws:

com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault

createAndStoreSubscriptionResource

public com.ebmwebsourcing.wsstar.addressing.datatypes.api.abstraction.EndpointReferenceType createAndStoreSubscriptionResource(java.lang.String subscriptionId,
                                                                                                                               java.util.List<com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.TopicExpressionType> topics,
                                                                                                                               com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.Subscribe payload)
                                                                                                                        throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException,
                                                                                                                               com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault

Throws:

com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault

removeAllSubscription

public java.util.List<java.lang.String> removeAllSubscription()
                                                       throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

Returns:

Throws:

com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

getConsumerEdpRefOfSubscription

public com.ebmwebsourcing.wsstar.addressing.datatypes.api.abstraction.EndpointReferenceType getConsumerEdpRefOfSubscription(java.lang.String subscriptionId)
                                                                                                                     throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

Throws:

com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

getSubscriptionRef

public com.ebmwebsourcing.wsstar.addressing.datatypes.api.abstraction.EndpointReferenceType getSubscriptionRef(java.lang.String subscriptionId)
                                                                                                        throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

Throws:

com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

getTopicExpressionOfSubscription

public java.util.List<com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.TopicExpressionType> getTopicExpressionOfSubscription(java.lang.String subscriptionId)
                                                                                                                                          throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

Throws:

com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

getFilterOfSubscription

public com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.FilterType getFilterOfSubscription(java.lang.String subscriptionId)
                                                                                                        throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

Throws:

com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

getPolicyOfSubscription

public com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.SubscriptionPolicyType getPolicyOfSubscription(java.lang.String subscriptionId)
                                                                                                                    throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

Throws:

com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

getTerminationTimeOfSubscription

public java.util.Date getTerminationTimeOfSubscription(java.lang.String subscriptionId)
                                                throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

Throws:

com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

removeExpiredSubscription

public void removeExpiredSubscription(java.lang.String subscriptionId)
                               throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

Throws:

com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

restorePersistedSubscriptions

public void restorePersistedSubscriptions(TopicsManagerEngine topicsMgr,
                                          org.w3c.dom.Document supportedTopicsAsDOM)
                                   throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException,
                                          com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault

Throws:

com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault

lookForSubscriptionToTerminate

public java.util.List<java.lang.String> lookForSubscriptionToTerminate(org.w3c.dom.Document topicSetAsDOM,
                                                                       TopicsManagerEngine wstopEngine)
                                                                throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

look for subscription which topics are no longer supported

Returns:

list of related subscription uuids

Throws:

com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

terminateSubscription

public void terminateSubscription(java.lang.String subscriptionUuid)
                           throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException,
                                  com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault

Throws:

com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault