Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

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

java.lang.Object
  extended by com.ebmwebsourcing.wsstar.wsnb.services.impl.engines.NotificationProducerEngine
All Implemented Interfaces:
com.ebmwebsourcing.wsstar.wsnb.services.INotificationProducer, com.ebmwebsourcing.wsstar.wsnb.services.INotificationProducerRP
public class NotificationProducerEngine
extends java.lang.Object
implements com.ebmwebsourcing.wsstar.wsnb.services.INotificationProducer, com.ebmwebsourcing.wsstar.wsnb.services.INotificationProducerRP

Author:
tdejean - eBM WebSourcing

Field Summary
protected  com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.NotificationProducerRP actorAsRP
           
protected  java.lang.String associatedNSPrefix
           
protected  java.util.Map<javax.xml.namespace.QName,java.util.List<com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.NotificationMessageHolderType.Message>> currentMessages
           
protected  java.util.logging.Logger logger
           
protected  com.ebmwebsourcing.wsstar.wsnb.services.transport.ITransporterForWsnbPublisher notificationSender
           
protected  SubscriptionManagerEngine subscriptionManagerService
           
protected  com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicNamespaceType topicNSForRPChangeValueNotif
           
protected  TopicsManagerEngine topicsManager
           
protected  java.lang.String wsnProducerEndpoint
           
protected  javax.xml.namespace.QName wsnProducerInterface
           
protected  javax.xml.namespace.QName wsnProducerService
           
 
Constructor Summary
NotificationProducerEngine(boolean isFixedTopicSet, com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicSetType supportedTopics, com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicNamespaceType topicNSForRPChangeNotif, java.lang.String prefixForNs, com.ebmwebsourcing.wsstar.wsnb.services.transport.ITransporterForWsnbPublisher transporter)
           
NotificationProducerEngine(java.util.logging.Logger logger, SubscriptionManagerEngine subsMgr, boolean isFixedTopicSet, com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicSetType supportedTopics, com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicNamespaceType topicNSForRPChangeNotif, java.lang.String prefixForNs, com.ebmwebsourcing.wsstar.wsnb.services.transport.ITransporterForWsnbPublisher transporter)
           
NotificationProducerEngine(java.util.logging.Logger logger, TopicsManagerEngine topicsMgr, SubscriptionManagerEngine subsMgr, boolean isFixedTopicSet, com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicSetType supportedTopics, com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicNamespaceType topicNSForRPChangeNotif, java.lang.String prefixForNs, com.ebmwebsourcing.wsstar.wsnb.services.transport.ITransporterForWsnbPublisher transporter)
           
 
Method Summary
 com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.NotificationProducerRP getActorAsRP()
           
 com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.GetCurrentMessageResponse getCurrentMessage(com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.GetCurrentMessage request)
           
 java.lang.String getNotificationProducerEdp()
           
 javax.xml.namespace.QName getNotificationProducerInterfaceQName()
           
 javax.xml.namespace.QName getNotificationProducerService()
           
 com.ebmwebsourcing.wsstar.resourceproperties.datatypes.api.abstraction.GetResourcePropertyResponse getResourceProperty(javax.xml.namespace.QName property)
           
 SubscriptionManagerEngine getSubsMgr()
           
 TopicsManagerEngine getTopicsMgr()
           
protected  void initActorAsRPAndAttributes(boolean isFixedTopicSet, com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicSetType supportedTopics)
           
 void setCurrentMessage(com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.TopicExpressionType topic, com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.NotificationMessageHolderType.Message notification, boolean isSameNotifyRequest)
          Method call to store the last notification (Message object) sent by the NotificationProducer service, according to WS-BaseNotification specification content ("GetCurrentMessage" operation in "NotificationProducer" interface description part)
 void setNotificationProducerEdp(java.lang.String notificationProducerEdp)
           
 void setNotificationProducerInterface(javax.xml.namespace.QName notificationProducerInterface)
           
 void setNotificationProducerService(javax.xml.namespace.QName notificationProducerService)
           
 void setTopicsMgr(TopicsManagerEngine topicsMgr)
           
 com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.SubscribeResponse subscribe(com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.Subscribe request)
           
 com.ebmwebsourcing.wsstar.resourceproperties.datatypes.api.abstraction.UpdateResourcePropertiesResponse updateResourceProperties(com.ebmwebsourcing.wsstar.resourceproperties.datatypes.api.abstraction.UpdateResourceProperties request)
           
 
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

wsnProducerEndpoint

protected java.lang.String wsnProducerEndpoint

wsnProducerService

protected javax.xml.namespace.QName wsnProducerService

wsnProducerInterface

protected javax.xml.namespace.QName wsnProducerInterface

actorAsRP

protected com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.NotificationProducerRP actorAsRP

topicNSForRPChangeValueNotif

protected com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicNamespaceType topicNSForRPChangeValueNotif

associatedNSPrefix

protected java.lang.String associatedNSPrefix

topicsManager

protected TopicsManagerEngine topicsManager

subscriptionManagerService

protected SubscriptionManagerEngine subscriptionManagerService

currentMessages

protected java.util.Map<javax.xml.namespace.QName,java.util.List<com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.NotificationMessageHolderType.Message>> currentMessages

notificationSender

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

NotificationProducerEngine

public NotificationProducerEngine(java.util.logging.Logger logger,
                                  TopicsManagerEngine topicsMgr,
                                  SubscriptionManagerEngine subsMgr,
                                  boolean isFixedTopicSet,
                                  com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicSetType supportedTopics,
                                  com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicNamespaceType topicNSForRPChangeNotif,
                                  java.lang.String prefixForNs,
                                  com.ebmwebsourcing.wsstar.wsnb.services.transport.ITransporterForWsnbPublisher transporter)
                           throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException
Throws:
com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

NotificationProducerEngine

public NotificationProducerEngine(java.util.logging.Logger logger,
                                  SubscriptionManagerEngine subsMgr,
                                  boolean isFixedTopicSet,
                                  com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicSetType supportedTopics,
                                  com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicNamespaceType topicNSForRPChangeNotif,
                                  java.lang.String prefixForNs,
                                  com.ebmwebsourcing.wsstar.wsnb.services.transport.ITransporterForWsnbPublisher transporter)
                           throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException
Throws:
com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

NotificationProducerEngine

public NotificationProducerEngine(boolean isFixedTopicSet,
                                  com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicSetType supportedTopics,
                                  com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicNamespaceType topicNSForRPChangeNotif,
                                  java.lang.String prefixForNs,
                                  com.ebmwebsourcing.wsstar.wsnb.services.transport.ITransporterForWsnbPublisher transporter)
                           throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException
Throws:
com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException
Method Detail

initActorAsRPAndAttributes

protected void initActorAsRPAndAttributes(boolean isFixedTopicSet,
                                          com.ebmwebsourcing.wsstar.topics.datatypes.api.abstraction.TopicSetType supportedTopics)
                                   throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException
Throws:
com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException

setNotificationProducerEdp

public void setNotificationProducerEdp(java.lang.String notificationProducerEdp)

getNotificationProducerEdp

public java.lang.String getNotificationProducerEdp()

setNotificationProducerService

public void setNotificationProducerService(javax.xml.namespace.QName notificationProducerService)

getNotificationProducerService

public javax.xml.namespace.QName getNotificationProducerService()

setNotificationProducerInterface

public void setNotificationProducerInterface(javax.xml.namespace.QName notificationProducerInterface)

getNotificationProducerInterfaceQName

public javax.xml.namespace.QName getNotificationProducerInterfaceQName()

getActorAsRP

public com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.NotificationProducerRP getActorAsRP()

getTopicsMgr

public TopicsManagerEngine getTopicsMgr()

setTopicsMgr

public void setTopicsMgr(TopicsManagerEngine topicsMgr)

getSubsMgr

public SubscriptionManagerEngine getSubsMgr()

getCurrentMessage

public com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.GetCurrentMessageResponse getCurrentMessage(com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.GetCurrentMessage request)
                                                                                                                 throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException,
                                                                                                                        com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault
Specified by:
getCurrentMessage in interface com.ebmwebsourcing.wsstar.wsnb.services.INotificationProducer
Throws:
com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException
com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault

setCurrentMessage

public void setCurrentMessage(com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.TopicExpressionType topic,
                              com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.NotificationMessageHolderType.Message notification,
                              boolean isSameNotifyRequest)
                       throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException,
                              com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault
Method call to store the last notification (Message object) sent by the NotificationProducer service, according to WS-BaseNotification specification content ("GetCurrentMessage" operation in "NotificationProducer" interface description part)

Parameters:
topic -
notification -
isSameNotifyRequest -
Throws:
com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException
com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault

subscribe

public com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.SubscribeResponse subscribe(com.ebmwebsourcing.wsstar.basenotification.datatypes.api.abstraction.Subscribe request)
                                                                                                 throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException,
                                                                                                        com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault
Specified by:
subscribe in interface com.ebmwebsourcing.wsstar.wsnb.services.INotificationProducer
Throws:
com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException
com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault

getResourceProperty

public com.ebmwebsourcing.wsstar.resourceproperties.datatypes.api.abstraction.GetResourcePropertyResponse getResourceProperty(javax.xml.namespace.QName property)
                                                                                                                       throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException,
                                                                                                                              com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault
Specified by:
getResourceProperty in interface com.ebmwebsourcing.wsstar.wsnb.services.INotificationProducerRP
Throws:
com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException
com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault

updateResourceProperties

public com.ebmwebsourcing.wsstar.resourceproperties.datatypes.api.abstraction.UpdateResourcePropertiesResponse updateResourceProperties(com.ebmwebsourcing.wsstar.resourceproperties.datatypes.api.abstraction.UpdateResourceProperties request)
                                                                                                                                 throws com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException,
                                                                                                                                        com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault
Specified by:
updateResourceProperties in interface com.ebmwebsourcing.wsstar.wsnb.services.INotificationProducerRP
Throws:
com.ebmwebsourcing.wsstar.basenotification.datatypes.api.utils.WsnbException
com.ebmwebsourcing.wsstar.wsrfbf.services.faults.AbsWSStarFault
Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD
Copyright © 2011 eBM Websourcing. All Rights Reserved.