You are viewing a plain text version of this content. The canonical link for it is here.
Posted to pubscribe-dev@ws.apache.org by ip...@apache.org on 2005/05/13 01:23:41 UTC
svn commit: r169910 - in
/incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06:
./ impl/ porttype/ porttype/impl/
Author: ips
Date: Thu May 12 16:23:40 2005
New Revision: 169910
URL: http://svn.apache.org/viewcvs?rev=169910&view=rev
Log:
fixed typo in package name
Added:
incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/
incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/BaseNotificationConstants.java
incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/
incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/SubscriptionHome.java
incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/SubscriptionResource.java
incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/SubscriptionService.java
incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/WsnNamespaceVersionHolderImpl.java
incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/
incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/NotificationConsumerPortType.java
incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/NotificationProducerPortType.java
incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/SubscriptionManagerPortType.java
incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/impl/
incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/impl/NotificationProducerPortTypeImpl.java
incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/impl/SubscriptionManagerPortTypeImpl.java
Added: incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/BaseNotificationConstants.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/BaseNotificationConstants.java?rev=169910&view=auto
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/BaseNotificationConstants.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/BaseNotificationConstants.java Thu May 12 16:23:40 2005
@@ -0,0 +1,49 @@
+/*=============================================================================*
+ * Copyright 2004 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *=============================================================================*/
+package org.apache.ws.notification.base.v2004_06;
+
+/**
+ * Constants defined by the WS-BaseNotification 1.2 Draft 01 specification.
+ */
+public interface BaseNotificationConstants
+{
+
+ /**
+ * Namespace URI of the WS-BaseNotification 1.2 Draft 01 schema.
+ */
+ String NSURI_WSNT_SCHEMA = "http://docs.oasis-open.org/wsn/2004/06/wsn-WS-BaseNotification-1.2-draft-01.xsd";
+
+ /**
+ * Namespace prefix for the WS-BaseNotification 1.2 Draft 01 schema.
+ */
+ String NSPREFIX_WSNT_SCHEMA = "wsnt";
+
+ /**
+ * Namespace URI of the WS-BaseNotification 1.2 Draft 01 WSDL.
+ */
+ String NSURI_WSNT_WSDL = "http://docs.oasis-open.org/wsn/2004/06/wsn-WS-BaseNotification-1.2-draft-01.wsdl";
+
+ /**
+ * Namespace prefix for the WS-BaseNotification 1.2 Draft 01 WSDL.
+ */
+ String NSPREFIX_WSNT_WSDL = "wsntw";
+
+ /**
+ * The value to use for the wsa:Action header in outgoing Notify messages.
+ */
+ String NOTIFY_ACTION_URL = BaseNotificationConstants.NSURI_WSNT_WSDL + "/Notify";
+
+}
Added: incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/SubscriptionHome.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/SubscriptionHome.java?rev=169910&view=auto
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/SubscriptionHome.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/SubscriptionHome.java Thu May 12 16:23:40 2005
@@ -0,0 +1,153 @@
+/*=============================================================================*
+ * Copyright 2004 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *=============================================================================*/
+package org.apache.ws.notification.base.v2004_06.impl;
+
+import org.apache.ws.addressing.EndpointReference;
+import org.apache.ws.notification.base.Subscription;
+import org.apache.ws.notification.base.WsnNamespaceVersionHolder;
+import org.apache.ws.notification.topics.expression.TopicExpression;
+import org.apache.ws.resource.JndiConstants;
+import org.apache.ws.resource.Resource;
+import org.apache.ws.resource.ResourceContext;
+import org.apache.ws.resource.ResourceContextException;
+import org.apache.ws.resource.ResourceException;
+import org.apache.ws.resource.ResourceKey;
+import org.apache.ws.resource.ResourceUnknownException;
+import org.apache.ws.resource.impl.AbstractResourceHome;
+import org.apache.ws.resource.impl.SimpleTypeResourceKey;
+import org.apache.ws.resource.properties.query.QueryExpression;
+
+import javax.xml.namespace.QName;
+import java.lang.reflect.Constructor;
+import java.util.Calendar;
+
+/**
+ * TODO
+ */
+public class SubscriptionHome extends AbstractResourceHome
+{
+
+ /**
+ * The service endpoint name as registered with the SOAP Platform. This is useful for building EPR's. *
+ */
+ public static final javax.xml.namespace.QName SERVICE_NAME = javax.xml.namespace.QName.valueOf(
+ "{http://ws.apache.org/notification/base/service/SubscriptionManager}SubscriptionManager" );
+
+ /**
+ * The management PortType associated with this resource. This is useful for building EPR's.*
+ */
+ public static final javax.xml.namespace.QName PORT_TYPE = javax.xml.namespace.QName.valueOf(
+ "http://ws.apache.org/notification/base/service/SubscriptionManager}SubscriptionManagerPortType" );
+
+ /**
+ * The WSDL Port name associated with the resource. This is useful for building EPR's. *
+ */
+ public static final String PORT_NAME = "SubscriptionManager";
+
+ /**
+ * The name of the resource key for this resource. *
+ */
+ public static final javax.xml.namespace.QName RESOURCE_KEY_NAME = javax.xml.namespace.QName.valueOf(
+ "{http://ws.apache.org/notification/base/service/SubscriptionManager}ResourceID" );
+
+ public static final String HOME_LOCATION = JndiConstants.CONTEXT_NAME_SERVICES + "/" + SERVICE_NAME.getLocalPart() +
+ "/" +
+ JndiConstants.ATOMIC_NAME_HOME;
+
+ /**
+ * @param resourceContext
+ *
+ * @return
+ *
+ * @throws ResourceException
+ * @throws ResourceContextException
+ * @throws ResourceUnknownException
+ */
+ public Resource getInstance( ResourceContext resourceContext ) throws ResourceException, ResourceContextException,
+ ResourceUnknownException
+ {
+ return find( resourceContext.getResourceKey() );
+ }
+
+ public Subscription create( Class subscriptionResourceClass,
+ EndpointReference consumerReference,
+ EndpointReference producerReference,
+ Calendar initialTerminationTime,
+ Object policy,
+ QueryExpression precondition,
+ QueryExpression selector,
+ ResourceKey producerKey,
+ String producerHomeLocation,
+ TopicExpression topicExpression,
+ boolean useNotify, WsnNamespaceVersionHolder nsSet ) throws ResourceException
+ {
+ try
+ {
+ Constructor constructor = subscriptionResourceClass.getConstructor( new Class[]{
+ EndpointReference.class,
+ EndpointReference.class,
+ ResourceKey.class,
+ String.class,
+ TopicExpression.class} );
+ Subscription subscription = (Subscription) constructor.newInstance(
+ new Object[]{consumerReference, producerReference, producerKey, producerHomeLocation,
+ topicExpression} );
+ subscription.setTerminationTime( initialTerminationTime );
+ subscription.setUseNotify( useNotify );
+ subscription.setSelector( selector );
+ subscription.setPrecondition( precondition );
+ subscription.setPolicy( policy );
+ subscription.init(); // initialize resource properties
+ String id = (String) subscription.getID();
+ SimpleTypeResourceKey resourceKey = new SimpleTypeResourceKey( QName.valueOf( getResourceKeyName() ), id );
+ EndpointReference subscriptionEPR = getEndpointReference( getSubscriptionAddress( producerReference ),
+ resourceKey, nsSet.getAddressingNamespace() );
+ subscription.setEndpointReference( subscriptionEPR );
+ add( resourceKey, subscription );
+ return subscription;
+ }
+ catch ( Exception e )
+ {
+ throw new ResourceException( "Failed to create Subscription resource." );
+ }
+ }
+
+ private String getSubscriptionAddress( EndpointReference producerReference )
+ {
+ String producerAddress = producerReference.getAddress();
+ return producerAddress.substring( 0, producerAddress.lastIndexOf( "/" ) + 1 ) + SERVICE_NAME;
+ }
+
+ public QName getServiceName()
+ {
+ return SERVICE_NAME;
+ }
+
+ public QName getPortType()
+ {
+ return PORT_TYPE;
+ }
+
+ public String getServicePortName()
+ {
+ return PORT_NAME;
+ }
+
+ public QName getResourceKeyNameQName()
+ {
+ return RESOURCE_KEY_NAME;
+ }
+}
Added: incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/SubscriptionResource.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/SubscriptionResource.java?rev=169910&view=auto
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/SubscriptionResource.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/SubscriptionResource.java Thu May 12 16:23:40 2005
@@ -0,0 +1,126 @@
+/*=============================================================================*
+ * Copyright 2004 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *=============================================================================*/
+package org.apache.ws.notification.base.v2004_06.impl;
+
+import org.apache.ws.XmlObjectWrapper;
+import org.apache.ws.addressing.EndpointReference;
+import org.apache.ws.notification.base.impl.AbstractSubscription;
+import org.apache.ws.notification.base.impl.XmlBeansTopicExpression;
+import org.apache.ws.notification.base.v2004_06.porttype.SubscriptionManagerPortType;
+import org.apache.ws.notification.topics.expression.TopicExpression;
+import org.apache.ws.pubsub.SubscriptionEndConsumer;
+import org.apache.ws.resource.ResourceKey;
+import org.apache.ws.resource.lifetime.v2004_06.porttype.ScheduledResourceTerminationPortType;
+import org.apache.ws.resource.properties.ResourceProperty;
+import org.apache.ws.resource.properties.ResourcePropertySet;
+import org.apache.ws.resource.properties.ResourcePropertySetMetaData;
+import org.apache.ws.resource.properties.impl.XmlBeansResourcePropertySet;
+import org.apache.ws.resource.properties.impl.XmlBeansResourcePropertySetMetaData;
+import org.apache.ws.resource.properties.query.impl.XmlBeansQueryExpression;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.ConsumerReferenceDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.CreationTimeDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.PreconditionDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.SelectorDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.SubscriptionManagerRPDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.SubscriptionPolicyDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.TopicExpressionDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.TopicExpressionType;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.UseNotifyDocument;
+import org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceLifetime12Draft01.CurrentTimeDocument;
+import org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceLifetime12Draft01.TerminationTimeDocument;
+import org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.QueryExpressionType;
+import org.xmlsoap.schemas.ws.x2003.x03.addressing.EndpointReferenceType;
+
+import javax.xml.namespace.QName;
+
+/**
+ * TODO
+ */
+public class SubscriptionResource extends AbstractSubscription
+{
+
+ private static final QName[] READ_ONLY_PROP_NAMES =
+ {
+ ScheduledResourceTerminationPortType.PROP_QNAME_CURRENT_TIME,
+ ScheduledResourceTerminationPortType.PROP_QNAME_TERMINATION_TIME,
+ SubscriptionManagerPortType.PROP_QNAME_CREATION_TIME
+ };
+
+ public SubscriptionResource( EndpointReference consumerReference, EndpointReference producerReference,
+ ResourceKey producerKey, String producerHomeLocation,
+ TopicExpression topicExpression )
+ {
+ super( consumerReference, producerReference,
+ producerKey, producerHomeLocation, topicExpression );
+ }
+
+ public void init()
+ {
+ SubscriptionManagerRPDocument propsDoc = SubscriptionManagerRPDocument.Factory.newInstance();
+ ResourcePropertySetMetaData propSetMetaData = new XmlBeansResourcePropertySetMetaData( propsDoc.schemaType(),
+ READ_ONLY_PROP_NAMES );
+ m_propSet = new XmlBeansResourcePropertySet( propsDoc, propSetMetaData );
+
+ // wsrlw:ScheduledResourceTermination props
+ ResourceProperty prop = m_propSet.get( ScheduledResourceTerminationPortType.PROP_QNAME_CURRENT_TIME );
+ CurrentTimeDocument currTimeDoc = CurrentTimeDocument.Factory.newInstance();
+ currTimeDoc.setCurrentTime( getCurrentTime() );
+ prop.add( currTimeDoc );
+ //prop.setCallback( new CurrentTimeCallback() );
+ prop = m_propSet.get( ScheduledResourceTerminationPortType.PROP_QNAME_TERMINATION_TIME );
+ TerminationTimeDocument termTimeDoc = TerminationTimeDocument.Factory.newInstance();
+ termTimeDoc.setTerminationTime( getTerminationTime() );
+ // wsntw:SubscriptionManager props
+ prop = m_propSet.get( SubscriptionManagerPortType.PROP_QNAME_CONSUMER_REFERENCE );
+ ConsumerReferenceDocument consumerRefDoc = ConsumerReferenceDocument.Factory.newInstance();
+ consumerRefDoc.setConsumerReference(
+ (EndpointReferenceType) ( (XmlObjectWrapper) m_consumerReference ).getXmlObject() );
+ prop = m_propSet.get( SubscriptionManagerPortType.PROP_QNAME_CREATION_TIME );
+ CreationTimeDocument creationTimeDoc = CreationTimeDocument.Factory.newInstance();
+ creationTimeDoc.setCreationTime( m_creationTime );
+ prop = m_propSet.get( SubscriptionManagerPortType.PROP_QNAME_PRECONDITION );
+ PreconditionDocument preconditionDoc = PreconditionDocument.Factory.newInstance();
+ preconditionDoc.setPrecondition(
+ (QueryExpressionType) ( (XmlBeansQueryExpression) m_precondition ).getXmlObject() );
+ prop = m_propSet.get( SubscriptionManagerPortType.PROP_QNAME_SELECTOR );
+ SelectorDocument selectorDoc = SelectorDocument.Factory.newInstance();
+ selectorDoc.setSelector( (QueryExpressionType) ( (XmlBeansQueryExpression) m_selector ).getXmlObject() );
+ prop = m_propSet.get( SubscriptionManagerPortType.PROP_QNAME_SUBSCRIPTION_POLICY );
+ SubscriptionPolicyDocument subPolicyDoc = SubscriptionPolicyDocument.Factory.newInstance();
+ subPolicyDoc.setSubscriptionPolicy( null );
+ prop = m_propSet.get( SubscriptionManagerPortType.PROP_QNAME_TOPIC_EXPRESSION );
+ TopicExpressionDocument topicExprDoc = TopicExpressionDocument.Factory.newInstance();
+ topicExprDoc.setTopicExpression( (TopicExpressionType) ( (XmlBeansTopicExpression) m_selector ).getXmlObject() );
+ prop = m_propSet.get( SubscriptionManagerPortType.PROP_QNAME_USE_NOTIFY );
+ UseNotifyDocument useNotifyDoc = UseNotifyDocument.Factory.newInstance();
+ useNotifyDoc.setUseNotify( m_useNotify );
+ }
+
+ public void setResourcePropertySet( ResourcePropertySet resourcePropertySet )
+ {
+ //todo
+ }
+
+ /**
+ * Get the subscriptionEnd consumer associated with this subscription.
+ *
+ * @return the subscriptionEnd consumer
+ */
+ public SubscriptionEndConsumer getSubscriptionEndConsumer()
+ {
+ return null; //todo
+ }
+}
Added: incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/SubscriptionService.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/SubscriptionService.java?rev=169910&view=auto
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/SubscriptionService.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/SubscriptionService.java Thu May 12 16:23:40 2005
@@ -0,0 +1,163 @@
+package org.apache.ws.notification.base.v2004_06.impl;
+
+import org.apache.ws.resource.handler.SoapMethodNameMap;
+import org.apache.ws.resource.handler.ServiceSoapMethodNameMap;
+import org.apache.ws.resource.handler.WsrfService;
+import org.apache.ws.resource.ResourceContext;
+import org.apache.ws.notification.base.v2004_06.porttype.SubscriptionManagerPortType;
+import org.apache.ws.notification.base.v2004_06.porttype.impl.SubscriptionManagerPortTypeImpl;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.PauseSubscriptionResponseDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.PauseSubscriptionDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.ResumeSubscriptionResponseDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.ResumeSubscriptionDocument;
+
+import javax.xml.namespace.QName;
+
+
+/**
+ * Implementation of the SubscriptionService
+ *
+ * @author Sal Campana
+ */
+public class SubscriptionService implements WsrfService , SubscriptionManagerPortType,
+ org.apache.ws.resource.lifetime.v2004_06.porttype.ScheduledResourceTerminationPortType,
+ org.apache.ws.resource.properties.v2004_06.porttype.GetResourcePropertyPortType,
+ org.apache.ws.resource.lifetime.v2004_06.porttype.ImmediateResourceTerminationPortType
+{
+ public static final String TARGET_NSURI = "http://ws.apache.org/notification/base/service/SubscriptionManager";
+ public static final String TARGET_NSPREFIX = "SubscriptionManager";
+ private ResourceContext m_resourceContext;
+ /**
+ * DOCUMENT_ME
+ */
+ private ServiceSoapMethodNameMap m_methodNameMap;
+
+ /**
+ * DOCUMENT_ME
+ */
+ private boolean m_isInitialized;
+
+ /**
+ * Creates a new {@link SubscriptionService } object.
+ *
+ * @param resourceContext DOCUMENT_ME
+ */
+ public SubscriptionService( ResourceContext resourceContext )
+ {
+ m_resourceContext = resourceContext;
+ init();
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param requestQname DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public String getMethodName( QName requestQname )
+ {
+ if ( !m_isInitialized )
+ {
+ init( );
+ }
+
+ return m_methodNameMap.getMethodName( requestQname );
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public ResourceContext getResourceContext( )
+ {
+ return m_resourceContext;
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public final SoapMethodNameMap getMethodNameMap( )
+ {
+ return m_methodNameMap;
+ }
+
+ /**
+ * DOCUMENT_ME
+ */
+ public void init( )
+ {
+ m_methodNameMap = new ServiceSoapMethodNameMap( getResourceContext( ) );
+ m_isInitialized = true;
+ }
+
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ protected final boolean isInitialized( )
+ {
+ return m_isInitialized;
+ }
+
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param requestDoc DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceLifetime12Draft01.SetTerminationTimeResponseDocument setTerminationTime( org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceLifetime12Draft01.SetTerminationTimeDocument requestDoc )
+ {
+ return new org.apache.ws.resource.lifetime.v2004_06.porttype.impl.ScheduledResourceTerminationPortTypeImpl( getResourceContext( ) ).setTerminationTime( requestDoc );
+ }
+ /**
+ * DOCUMENT_ME
+ *
+ * @param requestDoc DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.GetResourcePropertyResponseDocument getResourceProperty( org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.GetResourcePropertyDocument requestDoc )
+ {
+ return new org.apache.ws.resource.properties.v2004_06.porttype.impl.GetResourcePropertyPortTypeImpl( getResourceContext( ) ).getResourceProperty( requestDoc );
+ }
+
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param requestDoc DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceLifetime12Draft01.DestroyResponseDocument destroy( org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceLifetime12Draft01.DestroyDocument requestDoc )
+ {
+ return new org.apache.ws.resource.lifetime.v2004_06.porttype.impl.ImmediateResourceTerminationPortTypeImpl( getResourceContext( ) ).destroy( requestDoc );
+ }
+
+ /**
+ * @param requestDoc
+ * @return
+ */
+ public PauseSubscriptionResponseDocument pauseSubscription(PauseSubscriptionDocument requestDoc)
+ {
+ return new SubscriptionManagerPortTypeImpl(getResourceContext()).pauseSubscription(requestDoc);
+ }
+
+ /**
+ * @param requestDoc
+ * @return
+ */
+ public ResumeSubscriptionResponseDocument resumeSubscription(ResumeSubscriptionDocument requestDoc)
+ {
+ return new SubscriptionManagerPortTypeImpl(getResourceContext()).resumeSubscription(requestDoc);
+
+ }
+}
Added: incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/WsnNamespaceVersionHolderImpl.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/WsnNamespaceVersionHolderImpl.java?rev=169910&view=auto
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/WsnNamespaceVersionHolderImpl.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/impl/WsnNamespaceVersionHolderImpl.java Thu May 12 16:23:40 2005
@@ -0,0 +1,27 @@
+package org.apache.ws.notification.base.v2004_06.impl;
+
+import org.apache.ws.notification.base.WsnNamespaceVersionHolder;
+import org.apache.ws.notification.base.v2004_06.BaseNotificationConstants;
+import org.apache.ws.notification.topics.v2004_06.TopicsConstants;
+import org.apache.ws.resource.properties.v2004_06.impl.NamespaceVersionHolderImpl;
+
+/**
+ * @author Sal Campana
+ */
+public class WsnNamespaceVersionHolderImpl extends NamespaceVersionHolderImpl implements WsnNamespaceVersionHolder
+{
+ public String getTopicsXsdNamespace()
+ {
+ return TopicsConstants.NSURI_WSTOP_SCHEMA;
+ }
+
+ public String getBaseNotificationXsdNamespace()
+ {
+ return BaseNotificationConstants.NSURI_WSNT_SCHEMA;
+ }
+
+ public String getBrokeredNotificationXsdNamespace()
+ {
+ return "http://docs.oasis-open.org/wsn/2004/06/wsn-WS-BrokeredNotification-1.2-draft-01.xsd";
+ }
+}
Added: incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/NotificationConsumerPortType.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/NotificationConsumerPortType.java?rev=169910&view=auto
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/NotificationConsumerPortType.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/NotificationConsumerPortType.java Thu May 12 16:23:40 2005
@@ -0,0 +1,36 @@
+/*=============================================================================*
+ * Copyright 2004 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *=============================================================================*/
+package org.apache.ws.notification.base.v2004_06.porttype;
+
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.NotifyDocument;
+import org.apache.ws.notification.base.v2004_06.BaseNotificationConstants;
+
+import javax.xml.namespace.QName;
+
+/**
+ * The WS-BaseNotification NotificationConsumer portType.
+ */
+public interface NotificationConsumerPortType
+{
+
+ QName NAME = new QName( BaseNotificationConstants.NSURI_WSNT_WSDL, "NotificationConsumer", BaseNotificationConstants.NSPREFIX_WSNT_WSDL );
+
+ /**
+ * @param requestDoc
+ */
+ void notify( NotifyDocument requestDoc );
+
+}
Added: incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/NotificationProducerPortType.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/NotificationProducerPortType.java?rev=169910&view=auto
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/NotificationProducerPortType.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/NotificationProducerPortType.java Thu May 12 16:23:40 2005
@@ -0,0 +1,67 @@
+/*=============================================================================*
+ * Copyright 2004 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *=============================================================================*/
+package org.apache.ws.notification.base.v2004_06.porttype;
+
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.SubscribeResponseDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.SubscribeDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.GetCurrentMessageResponseDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.GetCurrentMessageDocument;
+import org.apache.ws.notification.base.v2004_06.BaseNotificationConstants;
+
+import javax.xml.namespace.QName;
+
+/**
+ * The WS-BaseNotification NotificationProducer portType.
+ */
+public interface NotificationProducerPortType
+{
+
+ QName NAME = new QName( BaseNotificationConstants.NSURI_WSNT_WSDL, "NotificationProducer", BaseNotificationConstants.NSPREFIX_WSNT_WSDL );
+ QName PROPS_DOC_NAME = new QName( BaseNotificationConstants.NSURI_WSNT_SCHEMA, "NotificationProducerRP", BaseNotificationConstants.NSPREFIX_WSNT_SCHEMA );
+
+ /**
+ * Topic property name.
+ */
+ QName PROP_QNAME_TOPIC = new QName( BaseNotificationConstants.NSURI_WSNT_SCHEMA,
+ "Topic", BaseNotificationConstants.NSPREFIX_WSNT_SCHEMA );
+
+ /**
+ * FixedTopicSet property name.
+ */
+ QName PROP_QNAME_FIXED_TOPIC_SET = new QName( BaseNotificationConstants.NSURI_WSNT_SCHEMA,
+ "FixedTopicSet", BaseNotificationConstants.NSPREFIX_WSNT_SCHEMA );
+
+ /**
+ * TopicExpressionDialects property name.
+ */
+ QName PROP_QNAME_TOPIC_EXPRESSION_DIALECTS = new QName( BaseNotificationConstants.NSURI_WSNT_SCHEMA,
+ "TopicExpressionDialects", BaseNotificationConstants.NSPREFIX_WSNT_SCHEMA );
+
+ /**
+ *
+ * @param requestDoc
+ * @return
+ */
+ SubscribeResponseDocument subscribe( SubscribeDocument requestDoc );
+
+ /**
+ *
+ * @param requestDoc
+ * @return
+ */
+ GetCurrentMessageResponseDocument getCurrentMessage( GetCurrentMessageDocument requestDoc );
+
+}
Added: incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/SubscriptionManagerPortType.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/SubscriptionManagerPortType.java?rev=169910&view=auto
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/SubscriptionManagerPortType.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/SubscriptionManagerPortType.java Thu May 12 16:23:40 2005
@@ -0,0 +1,93 @@
+/*=============================================================================*
+ * Copyright 2004 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *=============================================================================*/
+package org.apache.ws.notification.base.v2004_06.porttype;
+
+import org.apache.ws.notification.base.v2004_06.BaseNotificationConstants;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.PauseSubscriptionDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.PauseSubscriptionResponseDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.ResumeSubscriptionDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.ResumeSubscriptionResponseDocument;
+
+import javax.xml.namespace.QName;
+
+/**
+ * The WS-BaseNotification SubscriptionManager portType.
+ */
+public interface SubscriptionManagerPortType
+{
+
+ QName NAME = new QName( BaseNotificationConstants.NSURI_WSNT_WSDL, "SubscriptionManager",
+ BaseNotificationConstants.NSPREFIX_WSNT_WSDL );
+ QName PROPS_DOC_NAME = new QName( BaseNotificationConstants.NSURI_WSNT_SCHEMA, "SubscriptionManagerRP",
+ BaseNotificationConstants.NSPREFIX_WSNT_SCHEMA );
+
+ /**
+ * ConsumerReference property name.
+ */
+ QName PROP_QNAME_CONSUMER_REFERENCE = new QName( BaseNotificationConstants.NSURI_WSNT_SCHEMA,
+ "ConsumerReference", BaseNotificationConstants.NSPREFIX_WSNT_SCHEMA );
+
+ /**
+ * TopicExpression property name.
+ */
+ QName PROP_QNAME_TOPIC_EXPRESSION = new QName( BaseNotificationConstants.NSURI_WSNT_SCHEMA, "TopicExpression",
+ BaseNotificationConstants.NSPREFIX_WSNT_SCHEMA );
+
+ /**
+ * UseNotify property name.
+ */
+ QName PROP_QNAME_USE_NOTIFY = new QName( BaseNotificationConstants.NSURI_WSNT_SCHEMA, "UseNotify",
+ BaseNotificationConstants.NSPREFIX_WSNT_SCHEMA );
+
+ /**
+ * Precondition property name.
+ */
+ QName PROP_QNAME_PRECONDITION = new QName( BaseNotificationConstants.NSURI_WSNT_SCHEMA, "Precondition",
+ BaseNotificationConstants.NSPREFIX_WSNT_SCHEMA );
+
+ /**
+ * Selector property name.
+ */
+ QName PROP_QNAME_SELECTOR = new QName( BaseNotificationConstants.NSURI_WSNT_SCHEMA, "Selector",
+ BaseNotificationConstants.NSPREFIX_WSNT_SCHEMA );
+
+ /**
+ * SubscriptionPolicy property name.
+ */
+ QName PROP_QNAME_SUBSCRIPTION_POLICY = new QName( BaseNotificationConstants.NSURI_WSNT_SCHEMA,
+ "SubscriptionPolicy", BaseNotificationConstants.NSPREFIX_WSNT_SCHEMA );
+
+ /**
+ * CreationTime property name.
+ */
+ QName PROP_QNAME_CREATION_TIME = new QName( BaseNotificationConstants.NSURI_WSNT_SCHEMA, "CreationTime",
+ BaseNotificationConstants.NSPREFIX_WSNT_SCHEMA );
+
+ /**
+ * @param requestDoc
+ *
+ * @return
+ */
+ PauseSubscriptionResponseDocument pauseSubscription( PauseSubscriptionDocument requestDoc );
+
+ /**
+ * @param requestDoc
+ *
+ * @return
+ */
+ ResumeSubscriptionResponseDocument resumeSubscription( ResumeSubscriptionDocument requestDoc );
+
+}
Added: incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/impl/NotificationProducerPortTypeImpl.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/impl/NotificationProducerPortTypeImpl.java?rev=169910&view=auto
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/impl/NotificationProducerPortTypeImpl.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/impl/NotificationProducerPortTypeImpl.java Thu May 12 16:23:40 2005
@@ -0,0 +1,205 @@
+/*=============================================================================*
+ * Copyright 2004 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *=============================================================================*/
+package org.apache.ws.notification.base.v2004_06.porttype.impl;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.ws.XmlObjectWrapper;
+import org.apache.ws.addressing.EndpointReference;
+import org.apache.ws.addressing.XmlBeansEndpointReference;
+import org.apache.ws.notification.base.NotificationProducerResource;
+import org.apache.ws.notification.base.Subscription;
+import org.apache.ws.notification.base.WsnNamespaceVersionHolder;
+import org.apache.ws.notification.base.faults.InvalidTopicExpressionFaultException;
+import org.apache.ws.notification.base.faults.NoCurrentMessageOnTopicFaultException;
+import org.apache.ws.notification.base.faults.SubscribeCreationFailedFaultException;
+import org.apache.ws.notification.base.faults.TopicPathDialectUnknownFaultException;
+import org.apache.ws.notification.base.impl.XmlBeansTopicExpression;
+import org.apache.ws.notification.base.v2004_06.impl.SubscriptionHome;
+import org.apache.ws.notification.base.v2004_06.impl.SubscriptionResource;
+import org.apache.ws.notification.base.v2004_06.impl.WsnNamespaceVersionHolderImpl;
+import org.apache.ws.notification.base.v2004_06.porttype.NotificationProducerPortType;
+import org.apache.ws.notification.topics.Topic;
+import org.apache.ws.notification.topics.TopicSpaceSet;
+import org.apache.ws.notification.topics.expression.TopicExpression;
+import org.apache.ws.notification.topics.expression.TopicExpressionException;
+import org.apache.ws.notification.topics.expression.TopicPathDialectUnknownException;
+import org.apache.ws.notification.topics.impl.SubscriptionTopicListener;
+import org.apache.ws.resource.ResourceContext;
+import org.apache.ws.resource.faults.BaseFaultException;
+import org.apache.ws.resource.impl.AbstractResourceContext;
+import org.apache.ws.resource.properties.NamespaceVersionHolder;
+import org.apache.ws.resource.properties.impl.AbstractResourcePropertiesPortType;
+import org.apache.ws.resource.properties.query.QueryExpression;
+import org.apache.ws.resource.properties.query.impl.XmlBeansQueryExpression;
+import org.apache.ws.util.XmlBeanUtils;
+import org.apache.xmlbeans.XmlObject;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.GetCurrentMessageDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.GetCurrentMessageResponseDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.SubscribeDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.SubscribeResponseDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.TopicExpressionType;
+import org.xmlsoap.schemas.ws.x2003.x03.addressing.EndpointReferenceType;
+
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
+import java.util.Calendar;
+
+/**
+ * An implementation of the WS-BaseNotification NotificationProducer portType.
+ *
+ * @author Ian Springer (ian DOT springer AT hp DOT com)
+ */
+public class NotificationProducerPortTypeImpl extends AbstractResourcePropertiesPortType
+ implements NotificationProducerPortType
+{
+
+ private static final Log LOG = LogFactory.getLog(NotificationProducerPortTypeImpl.class.getName());
+
+ public NotificationProducerPortTypeImpl( ResourceContext resourceContext )
+ {
+ super( resourceContext );
+ }
+
+ /**
+ * @see NotificationProducerPortType#subscribe(org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.SubscribeDocument)
+ */
+ public SubscribeResponseDocument subscribe( SubscribeDocument requestDoc )
+ {
+ SubscribeDocument.Subscribe request = requestDoc.getSubscribe();
+ TopicExpression topicExpr = new XmlBeansTopicExpression( request.getTopicExpression() );
+ Topic[] topics = evaluateTopicExpression( topicExpr );
+ if ( topics.length == 0 )
+ {
+ throw new InvalidTopicExpressionFaultException( new WsnNamespaceVersionHolderImpl(),
+ "Given TopicExpression did not match any Topics supported by this NotificationProducer." );
+ }
+ Calendar initialTerminationTime = null;
+ if ( request.isSetInitialTerminationTime() )
+ {
+ initialTerminationTime = request.getInitialTerminationTime();
+ }
+ QueryExpression precondition = null;
+ if ( request.isSetPrecondition() )
+ {
+ precondition = new XmlBeansQueryExpression( request.getPrecondition() );
+ }
+ QueryExpression selector = null;
+ if ( request.isSetSelector() )
+ {
+ selector = new XmlBeansQueryExpression( request.getSelector() );
+ }
+ XmlObject subPolicy = null;
+ if ( request.isSetSubscriptionPolicy() )
+ {
+ subPolicy = request.getSubscriptionPolicy();
+ }
+ EndpointReferenceType subscriptionEPR = null;
+
+ //this prop has default values in schema...it "should" get a value either way if not explicitly set in request
+ boolean useNotify = request.isSetUseNotify() ? request.getUseNotify() : true;
+ EndpointReference producerEPR = getResource().getEndpointReference();
+ SubscriptionHome subscriptionHome = null;
+ try
+ {
+ subscriptionHome = (SubscriptionHome) new InitialContext().lookup(
+ SubscriptionHome.HOME_LOCATION );
+ }
+ catch ( NamingException ne )
+ {
+ LOG.error( "Subscribe failed due to internal error: " + ne );
+ throw new BaseFaultException( getNamespaceSet(), "Subscribe failed due to internal server error." );
+ }
+ Subscription subscription = null;
+ try
+ {
+ subscription = subscriptionHome.create( SubscriptionResource.class,
+ new XmlBeansEndpointReference( request.getConsumerReference() ), producerEPR, initialTerminationTime,
+ subPolicy, precondition, selector, getResourceKey(),
+ ( (AbstractResourceContext) getResourceContext() ).getResourceHomeLocation(), topicExpr, useNotify, (WsnNamespaceVersionHolder) getNamespaceSet() );
+ }
+ catch ( Exception e )
+ {
+ LOG.error( "Subscribe failed due to internal error: " + e );
+ if ( LOG.isDebugEnabled() )
+ {
+ e.printStackTrace( );
+ }
+ throw new SubscribeCreationFailedFaultException( (WsnNamespaceVersionHolder) getNamespaceSet() );
+ }
+ SubscriptionTopicListener subscriptionTopicListener = new SubscriptionTopicListener( subscription );
+ for ( int i = 0; i < topics.length; i++ )
+ {
+ topics[i].addTopicListener( subscriptionTopicListener );
+ }
+ SubscribeResponseDocument subscribeResponseDoc = SubscribeResponseDocument.Factory.newInstance();
+ SubscribeResponseDocument.SubscribeResponse subscribeResponse = subscribeResponseDoc.addNewSubscribeResponse();
+ subscriptionEPR = (EndpointReferenceType) ( (XmlObjectWrapper) subscription.getEndpointReference() ).getXmlObject();
+ subscribeResponse.setSubscriptionReference( subscriptionEPR );
+ return subscribeResponseDoc;
+ }
+
+ /**
+ * @see NotificationProducerPortType#getCurrentMessage(org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.GetCurrentMessageDocument)
+ */
+ public GetCurrentMessageResponseDocument getCurrentMessage( GetCurrentMessageDocument requestDoc )
+ {
+ GetCurrentMessageDocument.GetCurrentMessage request = requestDoc.getGetCurrentMessage();
+ TopicExpressionType topicExprXmlBean = request.getTopic();
+ TopicExpression topicExpr = new XmlBeansTopicExpression( topicExprXmlBean );
+ Topic[] topics = evaluateTopicExpression( topicExpr );
+ if ( topics.length != 1 )
+ {
+ throw new InvalidTopicExpressionFaultException( new WsnNamespaceVersionHolderImpl(),
+ "Given TopicExpression did not match exactly one Topic supported by this NotificationProducer." );
+ }
+ Topic topic = topics[0];
+ XmlObject currentMsg = (XmlObject) topic.getCurrentMessage();
+ if ( currentMsg == null )
+ {
+ throw new NoCurrentMessageOnTopicFaultException( (WsnNamespaceVersionHolder) getNamespaceSet() );
+ }
+ GetCurrentMessageResponseDocument responseDoc = GetCurrentMessageResponseDocument.Factory.newInstance();
+ GetCurrentMessageResponseDocument.GetCurrentMessageResponse response = responseDoc.addNewGetCurrentMessageResponse();
+ XmlBeanUtils.addChildElement( response, currentMsg );
+ return responseDoc;
+ }
+
+ private Topic[] evaluateTopicExpression( TopicExpression topicExpr )
+ {
+ try
+ {
+ NotificationProducerResource resource = (NotificationProducerResource) getResource();
+ TopicSpaceSet topicSpaceSet = resource.getTopicSpaceSet();
+ return topicSpaceSet.evaluateTopicExpression( topicExpr );
+ }
+ catch ( TopicPathDialectUnknownException tpdue )
+ {
+ throw new TopicPathDialectUnknownFaultException( (WsnNamespaceVersionHolder) getNamespaceSet(),
+ tpdue.getLocalizedMessage() );
+ }
+ catch ( TopicExpressionException tee )
+ {
+ throw new BaseFaultException( getNamespaceSet(), tee.getLocalizedMessage() );
+ }
+ }
+
+ protected NamespaceVersionHolder getNamespaceSet()
+ {
+ return new WsnNamespaceVersionHolderImpl();
+ }
+
+}
Added: incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/impl/SubscriptionManagerPortTypeImpl.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/impl/SubscriptionManagerPortTypeImpl.java?rev=169910&view=auto
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/impl/SubscriptionManagerPortTypeImpl.java (added)
+++ incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v2004_06/porttype/impl/SubscriptionManagerPortTypeImpl.java Thu May 12 16:23:40 2005
@@ -0,0 +1,94 @@
+/*=============================================================================*
+ * Copyright 2004 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *=============================================================================*/
+package org.apache.ws.notification.base.v2004_06.porttype.impl;
+
+import org.apache.ws.notification.base.faults.PauseFailedFaultException;
+import org.apache.ws.notification.base.faults.ResumeFailedFaultException;
+import org.apache.ws.notification.base.v2004_06.porttype.SubscriptionManagerPortType;
+import org.apache.ws.notification.base.v2004_06.impl.WsnNamespaceVersionHolderImpl;
+import org.apache.ws.resource.ResourceContext;
+import org.apache.ws.resource.properties.NamespaceVersionHolder;
+import org.apache.ws.resource.properties.impl.AbstractResourcePropertiesPortType;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.PauseSubscriptionDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.PauseSubscriptionResponseDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.ResumeSubscriptionDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.ResumeSubscriptionResponseDocument;
+import org.apache.ws.notification.base.Subscription;
+
+/**
+ * An implementation of the WS-BaseNotification SubscriptionManager portType.
+ *
+ * @author Ian Springer (ian DOT springer AT hp DOT com)
+ */
+public class SubscriptionManagerPortTypeImpl extends AbstractResourcePropertiesPortType
+ implements SubscriptionManagerPortType
+{
+
+ public SubscriptionManagerPortTypeImpl( ResourceContext resourceContext )
+ {
+ super( resourceContext );
+ }
+
+ public PauseSubscriptionResponseDocument pauseSubscription( PauseSubscriptionDocument requestDoc )
+ {
+ Subscription subscription = (Subscription) getResource();
+ try
+ {
+ subscription.pause();
+ }
+ catch ( Exception e )
+ {
+ throw new PauseFailedFaultException(new WsnNamespaceVersionHolderImpl(),"Pause failed on subscription: " + subscription.getID());
+ }
+ return createPauseSubscriptionResponseDocument();
+ }
+
+ public ResumeSubscriptionResponseDocument resumeSubscription( ResumeSubscriptionDocument requestDoc )
+ {
+ Subscription subscription = (Subscription) getResource();
+ try
+ {
+ subscription.resume();
+ }
+ catch ( Exception e )
+ {
+ throw new ResumeFailedFaultException(new WsnNamespaceVersionHolderImpl(),"Resume failed on subscription: " + subscription.getID());
+ }
+ return createResumeSubscriptionResponseDocument();
+ }
+
+ private PauseSubscriptionResponseDocument createPauseSubscriptionResponseDocument()
+ {
+ PauseSubscriptionResponseDocument responseDoc =
+ PauseSubscriptionResponseDocument.Factory.newInstance();
+ responseDoc.addNewPauseSubscriptionResponse();
+ return responseDoc;
+ }
+
+ private ResumeSubscriptionResponseDocument createResumeSubscriptionResponseDocument()
+ {
+ ResumeSubscriptionResponseDocument responseDoc =
+ ResumeSubscriptionResponseDocument.Factory.newInstance();
+ responseDoc.addNewResumeSubscriptionResponse();
+ return responseDoc;
+ }
+
+ protected NamespaceVersionHolder getNamespaceSet()
+ {
+ return null; // not currently used - will be needed once we need to support multiple spec versions
+ }
+
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: hermes-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: hermes-dev-help@ws.apache.org