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

java.lang.Object
  de.fzj.unicore.wsrflite.impl.WSRFInstanceImpl
      de.fzj.unicore.wsrflite.xmlbeans.impl.WSResourceImpl
          de.fzj.unicore.wsrflite.xmlbeans.wsn.impl.SubscriptionImpl

All Implemented Interfaces:

WSRFConstants, WSRFInstance, ResourceLifetime, ResourceProperties, ISubscription, WSResource

public class SubscriptionImpl
extends WSResourceImpl
implements ISubscription

implementation of the subscription ws-resource

Author:

schuller

Field Summary

static String	ConsumerRefKey
static String	CreationTimeKey
static String	FilterKey
protected static org.apache.log4j.Logger	logger
static String	MessageContentKey
static String	NotificationProducerRefKey
static String	SubscrPolicy

Fields inherited from class de.fzj.unicore.wsrflite.xmlbeans.impl.WSResourceImpl

DELETE, INSERT, 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.ISubscription

BASENS, RPConsumerReference, RPCreationTime, RPFilter, RPSubscriptionPolicy, SERVICENAME

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

SubscriptionImpl()

Method Summary

void	destroy() resource-specific destruction: send message about our demise
org.oasisOpen.docs.wsn.b2.ConsumerReferenceDocument	getConsumerReference()
org.oasisOpen.docs.wsn.b2.CreationTimeDocument	getCreationTime()
String	getMessageContentFilter()
QName	getResourcePropertyDocumentQName() returns the QName of the resource properties document
void	initialise(String serviceName, Map<String,Object> map) initialise this WS Resource In subclasses, a call to super.initialise() is highly recommended!
boolean	match(Event event) check if an event fits our filter
protected void	processFilter(org.oasisOpen.docs.wsn.b2.FilterDocument filter)

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, SetTerminationTime, UpdateResourceProperties

Methods inherited from class de.fzj.unicore.wsrflite.impl.WSRFInstanceImpl

clearChangeFlag, clearSecurityContext, getDefaultLifetime, getSecurityContext, getServiceName, getTerminationTime, getUniqueID, hasChanged, isDestroyed, isExpired, passivate, postActivate, 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, SetTerminationTime

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, getSecurityContext, getServiceName, getTerminationTime, getUniqueID, hasChanged, isDestroyed, isExpired, passivate, postActivate, processMessages, setHome, setSecurityContext, setServiceName, setUniqueID

Field Detail

logger

protected static final org.apache.log4j.Logger logger

ConsumerRefKey

public static final String ConsumerRefKey

FilterKey

public static final String FilterKey

MessageContentKey

public static final String MessageContentKey

SubscrPolicy

public static final String SubscrPolicy

CreationTimeKey

public static final String CreationTimeKey

NotificationProducerRefKey

public static final String NotificationProducerRefKey

Constructor Detail

SubscriptionImpl

public SubscriptionImpl()

Method Detail

initialise

public void initialise(String serviceName,
                       Map<String,Object> map)
                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

map - - a Map containing initialisation params

Throws:

Exception

processFilter

protected void processFilter(org.oasisOpen.docs.wsn.b2.FilterDocument filter)

destroy

public void destroy()

resource-specific destruction: send message about our demise

Specified by:

destroy in interface WSRFInstance

Overrides:

destroy in class WSRFInstanceImpl

getConsumerReference

public org.oasisOpen.docs.wsn.b2.ConsumerReferenceDocument getConsumerReference()

Specified by:

getConsumerReference in interface ISubscription

getMessageContentFilter

public String getMessageContentFilter()

Specified by:

getMessageContentFilter in interface ISubscription

getCreationTime

public org.oasisOpen.docs.wsn.b2.CreationTimeDocument getCreationTime()

Specified by:

getCreationTime in interface ISubscription

getResourcePropertyDocumentQName

public QName getResourcePropertyDocumentQName()

Description copied from class: WSResourceImpl

returns the QName of the resource properties document

Specified by:

getResourcePropertyDocumentQName in class WSResourceImpl

Returns:

match

public boolean match(Event event)

check if an event fits our filter

Specified by:

match in interface ISubscription