de.fzj.unicore.wsrflite.xmlbeans.wsn.impl
Class NotificationProducerImpl

java.lang.Object
  extended by de.fzj.unicore.wsrflite.impl.WSRFInstanceImpl
      extended by de.fzj.unicore.wsrflite.xmlbeans.impl.WSResourceImpl
          extended by de.fzj.unicore.wsrflite.xmlbeans.wsn.impl.NotificationProducerImpl
All Implemented Interfaces:
WSRFConstants, WSRFInstance, ResourceLifetime, ResourceProperties, NotificationProducer, WSNConstants, WSRFNotificationProducer, WSResource

public abstract class NotificationProducerImpl
extends WSResourceImpl
implements WSRFNotificationProducer

example for a notification producer using the NotificationProducerSupport class

Author:
schuller

Field Summary
protected  NotificationProducerSupport npSupport
           
 
Fields inherited from class de.fzj.unicore.wsrflite.xmlbeans.impl.WSResourceImpl
DELETE, INSERT, logger, properties, UPDATE
 
Fields inherited from class de.fzj.unicore.wsrflite.impl.WSRFInstanceImpl
home, INIT_INITIAL_TERMINATION_TIME, INIT_UNIQUE_ID, isDirty
 
Fields inherited from interface de.fzj.unicore.wsrflite.xmlbeans.wsn.NotificationProducer
GETCURRENTMESSAGE_ACTION, SUBSCRIBE_ACTION
 
Fields inherited from interface de.fzj.unicore.wsrflite.xmlbeans.wsn.WSNConstants
BW_BASENS, RPFixedTopicSet, RPTopicExpression, RPTopicExpressionDialect, RPTopicSet, SIMPLE_TOPIC, WSN_CHANNEL, XPATH_URI
 
Fields inherited from interface de.fzj.unicore.wsrflite.xmlbeans.ResourceProperties
WSRP_DELETE_RP, WSRP_GET_MULTIPLE_RP, WSRP_GET_RP, WSRP_GET_RP_DOCUMENT, WSRP_INSERT_RP, WSRP_PUT_RP_DOCUMENT, WSRP_QUERY_RP, WSRP_RP_QueryExpressionDialect, WSRP_SET_RP, WSRP_UPDATE_RP
 
Fields inherited from interface de.fzj.unicore.wsrflite.WSRFConstants
QUERY_EXPRESSION_DIALECT_XPATH, RPcurrentTimeQName, RPterminationTimeQName, WSRL_BASENS, WSRL_DESTROY, WSRL_DESTROY_PORT, WSRL_SCHEDULED, WSRL_SET_TERMTIME_PORT, WSRP_BASENS, WSRP_DELETE_RP_PORT, WSRP_GET_MULTIPLE_RP_PORT, WSRP_GET_RP_DOCUMENT_PORT, WSRP_GET_RP_PORT, WSRP_INSERT_RP_PORT, WSRP_PUT_RP_DOCUMENT_PORT, WSRP_QUERY_RP_PORT, WSRP_SET_RP_PORT, WSRP_UPDATE_RP_PORT
 
Constructor Summary
NotificationProducerImpl()
           
 
Method Summary
 org.oasisOpen.docs.wsn.b2.GetCurrentMessageResponseDocument GetCurrentMessage(org.oasisOpen.docs.wsn.b2.GetCurrentMessageDocument req)
           
 QName getResourcePropertyDocumentQName()
          returns the QName of the resource properties document
 void initialise(String serviceName, Map<String,Object> initobjs)
          initialise this WS Resource
In subclasses, a call to super.initialise() is highly recommended!
 Map<String,Serializable> passivate()
          called when the instance is persisted
 void postActivate()
          post-activation hook
this is called when the instance is reloaded into memory, after activate() has been called and the access control check has been passed
 org.oasisOpen.docs.wsrf.rl2.SetTerminationTimeResponseDocument SetTerminationTime(org.oasisOpen.docs.wsrf.rl2.SetTerminationTimeDocument in)
           
 org.oasisOpen.docs.wsn.b2.SubscribeResponseDocument Subscribe(org.oasisOpen.docs.wsn.b2.SubscribeDocument req)
           
 
Methods inherited from class de.fzj.unicore.wsrflite.xmlbeans.impl.WSResourceImpl
activate, DeleteResourceProperties, Destroy, fillResourcePropertyDocument, GetMultipleResourceProperties, GetResourceProperty, getResourceProperty, GetResourcePropertyDocument, getResourcePropertyObject, getResourcePropertyQNames, getResourcePropertyResponseDocument, getResourcePropertyXML, InsertResourceProperties, isModifyable, PutResourcePropertyDocument, QueryResourceProperties, SetResourceProperties, UpdateResourceProperties
 
Methods inherited from class de.fzj.unicore.wsrflite.impl.WSRFInstanceImpl
clearChangeFlag, clearSecurityContext, destroy, getDefaultLifetime, getSecurityContext, getServiceName, getTerminationTime, getUniqueID, hasChanged, isDestroyed, isExpired, processMessages, setDirty, setHome, setSecurityContext, setServiceName, setTerminationTime, setUniqueID
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface de.fzj.unicore.wsrflite.xmlbeans.ResourceLifetime
Destroy
 
Methods inherited from interface de.fzj.unicore.wsrflite.xmlbeans.ResourceProperties
DeleteResourceProperties, GetMultipleResourceProperties, GetResourceProperty, GetResourcePropertyDocument, InsertResourceProperties, PutResourcePropertyDocument, QueryResourceProperties, SetResourceProperties, UpdateResourceProperties
 
Methods inherited from interface de.fzj.unicore.wsrflite.WSRFInstance
activate, clearChangeFlag, clearSecurityContext, destroy, getSecurityContext, getServiceName, getTerminationTime, getUniqueID, hasChanged, isDestroyed, isExpired, processMessages, setHome, setSecurityContext, setServiceName, setUniqueID
 

Field Detail

npSupport

@Persist
protected NotificationProducerSupport npSupport
Constructor Detail

NotificationProducerImpl

public NotificationProducerImpl()
Method Detail

getResourcePropertyDocumentQName

public QName getResourcePropertyDocumentQName()
Description copied from class: WSResourceImpl
returns the QName of the resource properties document

Specified by:
getResourcePropertyDocumentQName in class WSResourceImpl
Returns:

GetCurrentMessage

public org.oasisOpen.docs.wsn.b2.GetCurrentMessageResponseDocument GetCurrentMessage(org.oasisOpen.docs.wsn.b2.GetCurrentMessageDocument req)
                                                                              throws BaseFault
Specified by:
GetCurrentMessage in interface NotificationProducer
Throws:
BaseFault

Subscribe

public org.oasisOpen.docs.wsn.b2.SubscribeResponseDocument Subscribe(org.oasisOpen.docs.wsn.b2.SubscribeDocument req)
                                                              throws BaseFault
Specified by:
Subscribe in interface NotificationProducer
Throws:
BaseFault

initialise

public void initialise(String serviceName,
                       Map<String,Object> initobjs)
                throws Exception
Description copied from class: WSResourceImpl
initialise this WS Resource
In subclasses, a call to super.initialise() is highly recommended!

Specified by:
initialise in interface WSRFInstance
Overrides:
initialise in class WSResourceImpl
Parameters:
serviceName - the service name this instance belongs to
initobjs - - a Map containing initialisation params
Throws:
Exception

SetTerminationTime

public org.oasisOpen.docs.wsrf.rl2.SetTerminationTimeResponseDocument SetTerminationTime(org.oasisOpen.docs.wsrf.rl2.SetTerminationTimeDocument in)
                                                                                  throws UnableToSetTerminationTimeFault,
                                                                                         TerminationTimeChangeRejectedFault,
                                                                                         ResourceUnknownFault,
                                                                                         ResourceUnavailableFault
Specified by:
SetTerminationTime in interface ResourceLifetime
Overrides:
SetTerminationTime in class WSResourceImpl
Throws:
UnableToSetTerminationTimeFault
TerminationTimeChangeRejectedFault
ResourceUnknownFault
ResourceUnavailableFault

passivate

public Map<String,Serializable> passivate()
Description copied from interface: WSRFInstance
called when the instance is persisted

Specified by:
passivate in interface WSRFInstance
Overrides:
passivate in class WSRFInstanceImpl
Returns:
context a map containing the state of the WS-Resource

postActivate

public void postActivate()
Description copied from interface: WSRFInstance
post-activation hook
this is called when the instance is reloaded into memory, after activate() has been called and the access control check has been passed

Specified by:
postActivate in interface WSRFInstance
Overrides:
postActivate in class WSRFInstanceImpl


Copyright © 2010. All Rights Reserved.