servicemix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gno...@apache.org
Subject svn commit: r357814 [2/3] - in /incubator/servicemix/trunk/servicemix-wsn2005: ./ src/ src/main/ src/main/java/ src/main/java/org/ src/main/java/org/servicemix/ src/main/java/org/servicemix/wsn/ src/main/java/org/servicemix/wsn/component/ src/main/java...
Date Mon, 19 Dec 2005 22:08:52 GMT
Added: incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsPublisher.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsPublisher.java?rev=357814&view=auto
==============================================================================
--- incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsPublisher.java (added)
+++ incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsPublisher.java Mon Dec 19 14:08:30 2005
@@ -0,0 +1,77 @@
+package org.servicemix.wsn.jms;
+
+import java.io.StringWriter;
+
+import javax.jms.Connection;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageProducer;
+import javax.jms.Session;
+import javax.jms.Topic;
+import javax.xml.bind.JAXBContext;
+import javax.xml.bind.JAXBException;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.oasis_open.docs.wsn.b_1.NotificationMessageHolderType;
+import org.oasis_open.docs.wsn.b_1.Notify;
+import org.servicemix.wsn.AbstractPublisher;
+import org.servicemix.wsn.jaxws.TopicExpressionDialectUnknownFault;
+
+public class JmsPublisher extends AbstractPublisher {
+
+	private static Log log = LogFactory.getLog(JmsPublisher.class);
+	
+	private Connection connection;
+	private JmsTopicExpressionConverter topicConverter;
+	private JAXBContext jaxbContext;
+
+	public JmsPublisher(String name) {
+		super(name);
+		topicConverter = new JmsTopicExpressionConverter();
+		try {
+			jaxbContext = JAXBContext.newInstance(Notify.class);
+		} catch (JAXBException e) {
+			throw new RuntimeException("Unable to create JAXB context", e);
+		}
+	}
+
+	@Override
+	public void notify(NotificationMessageHolderType messageHolder) {
+		Session session = null;
+		try {
+            Topic topic = topicConverter.toActiveMQTopic(messageHolder.getTopic());
+			session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+            MessageProducer producer = session.createProducer(topic);
+            Notify notify = new Notify();
+            notify.getNotificationMessage().add(messageHolder);
+            StringWriter writer = new StringWriter();
+            jaxbContext.createMarshaller().marshal(notify, writer);
+            Message message = session.createTextMessage(writer.toString());
+            producer.send(message);
+		} catch (JMSException e) {
+			log.warn("Error dispatching message", e);
+		} catch (JAXBException e) {
+			log.warn("Error dispatching message", e);
+		} catch (TopicExpressionDialectUnknownFault e) {
+			log.warn("Error dispatching message", e);
+		} finally {
+			if (session != null) {
+				try {
+					session.close();
+				} catch (JMSException e) {
+					log.debug("Error closing session", e);
+				}
+			}
+		}
+	}
+
+	public Connection getConnection() {
+		return connection;
+	}
+
+	public void setConnection(Connection connection) {
+		this.connection = connection;
+	}
+
+}

Added: incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsPullPoint.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsPullPoint.java?rev=357814&view=auto
==============================================================================
--- incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsPullPoint.java (added)
+++ incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsPullPoint.java Mon Dec 19 14:08:30 2005
@@ -0,0 +1,132 @@
+package org.servicemix.wsn.jms;
+
+import java.io.StringReader;
+import java.io.StringWriter;
+import java.util.ArrayList;
+import java.util.List;
+
+import javax.jms.Connection;
+import javax.jms.DeliveryMode;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageConsumer;
+import javax.jms.MessageProducer;
+import javax.jms.Queue;
+import javax.jms.Session;
+import javax.jms.TextMessage;
+import javax.xml.bind.JAXBContext;
+import javax.xml.bind.JAXBException;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.oasis_open.docs.wsn.b_1.NotificationMessageHolderType;
+import org.oasis_open.docs.wsn.b_1.Notify;
+import org.oasis_open.docs.wsrf.r_1.ResourceUnknownFaultType;
+import org.servicemix.wsn.AbstractPullPoint;
+import org.servicemix.wsn.jaxws.ResourceUnknownFault;
+
+public class JmsPullPoint extends AbstractPullPoint {
+
+	private static Log log = LogFactory.getLog(JmsPullPoint.class);
+	
+	private JAXBContext jaxbContext;
+	private Connection connection;
+	private Session session;
+	private Queue queue;
+	private MessageProducer producer;
+	private MessageConsumer consumer;
+
+	public JmsPullPoint(String name)  {
+		super(name);
+		try {
+			jaxbContext = JAXBContext.newInstance(Notify.class);
+		} catch (JAXBException e) {
+			throw new RuntimeException("Could not create PullEndpoint", e);
+		}
+	}
+	
+	protected void initSession() throws JMSException {
+		if (session == null) {
+			session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+			queue = session.createQueue(getName());
+			producer = session.createProducer(queue);
+			producer.setDeliveryMode(DeliveryMode.PERSISTENT);
+			consumer = session.createConsumer(queue);
+		}
+	}
+
+	@Override
+	protected synchronized void store(NotificationMessageHolderType messageHolder) {
+		try {
+			initSession();
+            Notify notify = new Notify();
+            notify.getNotificationMessage().add(messageHolder);
+            StringWriter writer = new StringWriter();
+            jaxbContext.createMarshaller().marshal(notify, writer);
+            Message message = session.createTextMessage(writer.toString());
+            producer.send(message);
+		} catch (JMSException e) {
+			log.warn("Error storing message", e);
+			if (session != null) {
+				try {
+					session.close();
+				} catch (JMSException inner) {
+					log.debug("Error closing session", inner);
+				} finally {
+					session = null;
+				}
+			}
+		} catch (JAXBException e) {
+			log.warn("Error storing message", e);
+		}
+	}
+
+	@Override
+	protected synchronized List<NotificationMessageHolderType> getMessages(int max) throws ResourceUnknownFault {
+		Session session = null;
+		try {
+			if (max == 0) {
+				max = 256;
+			}
+			initSession();
+			List<NotificationMessageHolderType> messages = new ArrayList<NotificationMessageHolderType>();
+			for (int i = 0; i < max; i++) {
+				Message msg = consumer.receiveNoWait();
+				if (msg == null) {
+					break;
+				}
+				TextMessage txtMsg = (TextMessage) msg;
+				StringReader reader = new StringReader(txtMsg.getText());
+				Notify notify = (Notify) jaxbContext.createUnmarshaller().unmarshal(reader);
+				messages.addAll(notify.getNotificationMessage());
+			}
+			return messages;
+		} catch (JMSException e) {
+			log.info("Error retrieving messages", e);
+			if (session != null) {
+				try {
+					session.close();
+				} catch (JMSException inner) {
+					log.debug("Error closing session", inner);
+				} finally {
+					session = null;
+				}
+			}
+			ResourceUnknownFaultType fault = new ResourceUnknownFaultType();
+			throw new ResourceUnknownFault("Unable to retrieve messages", fault, e);
+		} catch (JAXBException e) {
+			log.info("Error retrieving messages", e);
+			ResourceUnknownFaultType fault = new ResourceUnknownFaultType();
+			throw new ResourceUnknownFault("Unable to retrieve messages", fault, e);
+		}
+	}
+	
+	public Connection getConnection() {
+		return connection;
+	}
+
+	public void setConnection(Connection connection) {
+		this.connection = connection;
+	}
+
+}

Added: incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsSubscription.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsSubscription.java?rev=357814&view=auto
==============================================================================
--- incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsSubscription.java (added)
+++ incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsSubscription.java Mon Dec 19 14:08:30 2005
@@ -0,0 +1,135 @@
+package org.servicemix.wsn.jms;
+
+import javax.jms.Connection;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageConsumer;
+import javax.jms.MessageListener;
+import javax.jms.Session;
+import javax.jms.TextMessage;
+import javax.jms.Topic;
+import javax.xml.datatype.XMLGregorianCalendar;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.oasis_open.docs.wsn.b_1.PauseFailedFaultType;
+import org.oasis_open.docs.wsn.b_1.ResumeFailedFaultType;
+import org.oasis_open.docs.wsn.b_1.Subscribe;
+import org.oasis_open.docs.wsn.b_1.SubscribeCreationFailedFaultType;
+import org.oasis_open.docs.wsn.b_1.UnableToDestroySubscriptionFaultType;
+import org.oasis_open.docs.wsn.b_1.UnacceptableTerminationTimeFaultType;
+import org.servicemix.wsn.AbstractSubscription;
+import org.servicemix.wsn.jaxws.InvalidFilterFault;
+import org.servicemix.wsn.jaxws.InvalidMessageContentExpressionFault;
+import org.servicemix.wsn.jaxws.InvalidProducerPropertiesExpressionFault;
+import org.servicemix.wsn.jaxws.InvalidTopicExpressionFault;
+import org.servicemix.wsn.jaxws.InvalidUseRawValueFault;
+import org.servicemix.wsn.jaxws.PauseFailedFault;
+import org.servicemix.wsn.jaxws.ResumeFailedFault;
+import org.servicemix.wsn.jaxws.SubscribeCreationFailedFault;
+import org.servicemix.wsn.jaxws.TopicExpressionDialectUnknownFault;
+import org.servicemix.wsn.jaxws.TopicNotSupportedFault;
+import org.servicemix.wsn.jaxws.UnableToDestroySubscriptionFault;
+import org.servicemix.wsn.jaxws.UnacceptableInitialTerminationTimeFault;
+import org.servicemix.wsn.jaxws.UnacceptableTerminationTimeFault;
+
+public abstract class JmsSubscription extends AbstractSubscription implements MessageListener {
+
+	private static Log log = LogFactory.getLog(JmsSubscription.class);
+	
+	private Connection connection;
+	private Session session;
+    private MessageConsumer consumer;
+    private JmsTopicExpressionConverter topicConverter;
+    private Topic jmsTopic;
+	
+	public JmsSubscription(String name) {
+		super(name);
+		topicConverter = new JmsTopicExpressionConverter();
+	}
+
+	protected void start() throws SubscribeCreationFailedFault {
+		try {
+			session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+            consumer = session.createConsumer(jmsTopic);
+            consumer.setMessageListener(this);
+		} catch (JMSException e) {
+			SubscribeCreationFailedFaultType fault = new SubscribeCreationFailedFaultType();
+			throw new SubscribeCreationFailedFault("Error starting subscription", fault, e);
+		}
+	}
+	
+	@Override
+	protected void validateSubscription(Subscribe subscribeRequest) throws InvalidFilterFault, InvalidMessageContentExpressionFault, InvalidProducerPropertiesExpressionFault, InvalidTopicExpressionFault, InvalidUseRawValueFault, SubscribeCreationFailedFault, TopicExpressionDialectUnknownFault, TopicNotSupportedFault, UnacceptableInitialTerminationTimeFault {
+		super.validateSubscription(subscribeRequest);
+		jmsTopic = topicConverter.toActiveMQTopic(topic);
+	}
+	
+	@Override
+	public void subscribe(Subscribe subscribeRequest) throws InvalidFilterFault, InvalidMessageContentExpressionFault, InvalidProducerPropertiesExpressionFault, InvalidTopicExpressionFault, InvalidUseRawValueFault, SubscribeCreationFailedFault, TopicExpressionDialectUnknownFault, TopicNotSupportedFault, UnacceptableInitialTerminationTimeFault {
+		validateSubscription(subscribeRequest);
+		start();
+	}
+
+	@Override
+	protected void pause() throws PauseFailedFault {
+		PauseFailedFaultType fault = new PauseFailedFaultType();
+		throw new PauseFailedFault("Pause not supported", fault);
+	}
+
+	@Override
+	protected void resume() throws ResumeFailedFault {
+		ResumeFailedFaultType fault = new ResumeFailedFaultType();
+		throw new ResumeFailedFault("Resume not supported", fault);
+	}
+
+	@Override
+	protected void renew(XMLGregorianCalendar terminationTime) throws UnacceptableTerminationTimeFault {
+		UnacceptableTerminationTimeFaultType fault = new UnacceptableTerminationTimeFaultType();
+    	throw new UnacceptableTerminationTimeFault(
+    			"TerminationTime is not supported",
+    			fault);
+	}
+
+	@Override
+	protected void unsubscribe() throws UnableToDestroySubscriptionFault {
+		if (session != null) {
+			try {
+				session.close();
+			} catch (JMSException e) {
+				UnableToDestroySubscriptionFaultType fault = new UnableToDestroySubscriptionFaultType();
+				throw new UnableToDestroySubscriptionFault("Unable to unsubscribe", fault, e);
+			}
+		}
+	}
+
+	public Connection getConnection() {
+		return connection;
+	}
+
+	public void setConnection(Connection connection) {
+		this.connection = connection;
+	}
+
+	public void onMessage(Message message) {
+		try {
+			TextMessage text = (TextMessage) message;
+	        boolean match = true;
+			if (contentFilter != null) {
+				match = doFilter(text.getText());
+			}
+			if (match) {
+				doNotify(text.getText());
+			}
+		} catch (Exception e) {
+			log.warn("Error notifying consumer", e);
+		}
+	}
+	
+	protected boolean doFilter(String notify) {
+		return true;
+	}
+	
+	protected abstract void doNotify(String notify);
+
+}

Added: incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsTopicExpressionConverter.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsTopicExpressionConverter.java?rev=357814&view=auto
==============================================================================
--- incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsTopicExpressionConverter.java (added)
+++ incubator/servicemix/trunk/servicemix-wsn2005/src/main/java/org/servicemix/wsn/jms/JmsTopicExpressionConverter.java Mon Dec 19 14:08:30 2005
@@ -0,0 +1,99 @@
+/**
+ *
+ * Copyright 2005 LogicBlaze, Inc. http://www.logicblaze.com
+ *
+ * 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.servicemix.wsn.jms;
+
+import java.util.Iterator;
+import java.util.List;
+
+import javax.jms.Topic;
+import javax.xml.namespace.QName;
+
+import org.activemq.command.ActiveMQTopic;
+import org.oasis_open.docs.wsn.b_1.TopicExpressionDialectUnknownFaultType;
+import org.oasis_open.docs.wsn.b_1.TopicExpressionType;
+import org.servicemix.wsn.jaxws.TopicExpressionDialectUnknownFault;
+
+public class JmsTopicExpressionConverter {
+
+    public static final String SIMPLE_DIALECT = "http://docs.oasis-open.org/wsn/t-1/TopicExpression/Simple";
+
+    public TopicExpressionType toTopicExpression(Topic topic) {
+        return toTopicExpression(topic.toString());
+    }
+
+    public TopicExpressionType toTopicExpression(ActiveMQTopic topic) {
+        return toTopicExpression(topic.getPhysicalName());
+    }
+
+    public TopicExpressionType toTopicExpression(String name) {
+        TopicExpressionType answer = new TopicExpressionType();
+        answer.getContent().add(QName.valueOf(name));
+        answer.setDialect(SIMPLE_DIALECT);
+        return answer;
+    }
+
+    public ActiveMQTopic toActiveMQTopic(List<TopicExpressionType> topics) throws TopicExpressionDialectUnknownFault {
+        if (topics == null || topics.size() == 0) {
+            return null;
+        }
+        int size = topics.size();
+        ActiveMQTopic childrenDestinations[] = new ActiveMQTopic[size];
+        for (int i = 0; i < size; i++) {
+            childrenDestinations[i] = toActiveMQTopic(topics.get(i));
+        }
+
+        ActiveMQTopic topic = new ActiveMQTopic();
+        topic.setCompositeDestinations(childrenDestinations);
+        //topic.setChildDestinations(childrenDestinations);
+        return topic;
+    }
+
+    public ActiveMQTopic toActiveMQTopic(TopicExpressionType topic) throws TopicExpressionDialectUnknownFault {
+        String dialect = topic.getDialect();
+        if (dialect == null || SIMPLE_DIALECT.equals(dialect)) {
+            for (Iterator iter = topic.getContent().iterator(); iter.hasNext();) {
+                ActiveMQTopic answer = createActiveMQTopicFromContent(iter.next());
+                if (answer != null) {
+                    return answer;
+                }
+            }
+            throw new RuntimeException("No topic name available topic: " + topic);
+        }
+        else {
+        	TopicExpressionDialectUnknownFaultType fault = new TopicExpressionDialectUnknownFaultType();
+        	throw new TopicExpressionDialectUnknownFault("Topic dialect: " + dialect + " not supported", fault);
+        }
+    }
+
+    // Implementation methods
+    // -------------------------------------------------------------------------
+    protected ActiveMQTopic createActiveMQTopicFromContent(Object contentItem) {
+        if (contentItem instanceof String) {
+            return new ActiveMQTopic(((String) contentItem).trim());
+        }
+        if (contentItem instanceof QName) {
+            return createActiveMQTopicFromQName((QName) contentItem);
+        }
+        return null;
+    }
+
+    protected ActiveMQTopic createActiveMQTopicFromQName(QName qName) {
+        return new ActiveMQTopic(qName.toString());
+    }
+
+}

Added: incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/b-1.xsd
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/b-1.xsd?rev=357814&view=auto
==============================================================================
--- incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/b-1.xsd (added)
+++ incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/b-1.xsd Mon Dec 19 14:08:30 2005
@@ -0,0 +1,446 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!-- 
+
+OASIS takes no position regarding the validity or scope of any intellectual property or other rights that might be claimed to pertain to the implementation or use of the technology described in this document or the extent to which any license under such rights might or might not be available; neither does it represent that it has made any effort to identify any such rights. Information on OASIS's procedures with respect to rights in OASIS specifications can be found at the OASIS website. Copies of claims of rights made available for publication and any assurances of licenses to be made available, or the result of an attempt made to obtain a general license or permission for the use of such proprietary rights by implementors or users of this specification, can be obtained from the OASIS Executive Director.
+
+OASIS invites any interested party to bring to its attention any copyrights, patents or patent applications, or other proprietary rights which may cover technology that may be required to implement this specification. Please address the information to the OASIS Executive Director.
+
+Copyright (C) OASIS Open (2004-2005). All Rights Reserved.
+
+This document and translations of it may be copied and furnished to others, and derivative works that comment on or otherwise explain it or assist in its implementation may be prepared, copied, published and distributed, in whole or in part, without restriction of any kind, provided that the above copyright notice and this paragraph are included on all such copies and derivative works. However, this document itself may not be modified in any way, such as by removing the copyright notice or references to OASIS, except as needed for the purpose of developing OASIS specifications, in which case the procedures for copyrights defined in the OASIS Intellectual Property Rights document must be followed, or as required to translate it into languages other than English. 
+
+The limited permissions granted above are perpetual and will not be revoked by OASIS or its successors or assigns. 
+
+This document and the information contained herein is provided on an "AS IS" basis and OASIS DISCLAIMS ALL WARRANTIES, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO ANY WARRANTY THAT THE USE OF THE INFORMATION HEREIN WILL NOT INFRINGE ANY RIGHTS OR ANY IMPLIED WARRANTIES OF MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE.
+
+-->
+<xsd:schema xmlns:wsa="http://www.w3.org/2005/03/addressing" xmlns:wsnt="http://docs.oasis-open.org/wsn/b-1" xmlns:wsrf-bf="http://docs.oasis-open.org/wsrf/bf-1" xmlns:xsd="http://www.w3.org/2001/XMLSchema" attributeFormDefault="unqualified" elementFormDefault="qualified" targetNamespace="http://docs.oasis-open.org/wsn/b-1">
+
+<!-- ======================== Imports  ============================ -->
+  
+  <xsd:import namespace="http://www.w3.org/2005/03/addressing" schemaLocation="wsa.xsd"/>
+
+  <xsd:import namespace="http://docs.oasis-open.org/wsrf/bf-1" schemaLocation="bf-1.xsd"/>
+  
+<!-- ===================== Misc. Helper Types ===================== -->
+
+  <xsd:complexType mixed="true" name="QueryExpressionType">
+    <xsd:sequence>
+      <xsd:any maxOccurs="1" minOccurs="0" processContents="lax"/>
+    </xsd:sequence>
+    <xsd:attribute name="Dialect" type="xsd:anyURI" use="required"/>
+  </xsd:complexType>
+
+  <xsd:complexType mixed="true" name="TopicExpressionType">
+    <xsd:sequence>
+      <xsd:any maxOccurs="1" minOccurs="0" processContents="lax"/>
+    </xsd:sequence>
+    <xsd:attribute name="Dialect" type="xsd:anyURI" use="required"/>
+    <xsd:anyAttribute/>
+  </xsd:complexType>
+
+  <xsd:complexType name="FilterType">
+    <xsd:sequence>
+      <xsd:any maxOccurs="unbounded" minOccurs="0"/>
+    </xsd:sequence>
+  </xsd:complexType>
+
+<!-- =============== Resource Property Related  =================== -->
+<!-- ======== Resource Properties for NotificationProducer ======== -->
+  <xsd:element name="TopicExpression" type="wsnt:TopicExpressionType"/>
+  <xsd:element default="true" name="FixedTopicSet" type="xsd:boolean"/>
+  <xsd:element name="TopicExpressionDialect" type="xsd:anyURI"/>
+              
+  <xsd:element name="NotificationProducerRP">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:element maxOccurs="unbounded" minOccurs="0" ref="wsnt:TopicExpression"/>
+        <xsd:element maxOccurs="1" minOccurs="0" ref="wsnt:FixedTopicSet"/>
+        <xsd:element maxOccurs="unbounded" minOccurs="0" ref="wsnt:TopicExpressionDialect"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+
+<!-- ======== Resource Properties for SubscriptionManager ========= -->       
+  <xsd:element name="ConsumerReference" type="wsa:EndpointReferenceType"/>
+  <xsd:element name="Filter" type="wsnt:FilterType"/>
+  <xsd:element name="SubscriptionPolicy">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" processContents="lax"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:element name="CreationTime" type="xsd:dateTime"/>
+  
+  <xsd:element name="SubscriptionManagerRP">
+    <xsd:complexType>
+      <xsd:sequence>
+         <xsd:element maxOccurs="1" minOccurs="1" ref="wsnt:ConsumerReference"/>
+         <xsd:element maxOccurs="1" minOccurs="0" ref="wsnt:Filter"/>
+         <xsd:element maxOccurs="1" minOccurs="0" ref="wsnt:SubscriptionPolicy"/>
+         <xsd:element maxOccurs="1" minOccurs="0" ref="wsnt:CreationTime"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+
+<!-- ================= Notification Metadata  ===================== -->
+  <xsd:element name="SubscriptionReference" type="wsa:EndpointReferenceType"/>
+  <xsd:element name="Topic" type="wsnt:TopicExpressionType"/>
+  <xsd:element name="ProducerReference" type="wsa:EndpointReferenceType"/>
+
+<!-- ================== Message Helper Types  ===================== -->
+  <xsd:complexType name="NotificationMessageHolderType">
+    <xsd:sequence>
+      <xsd:element maxOccurs="1" minOccurs="0" ref="wsnt:SubscriptionReference"/>
+      <xsd:element maxOccurs="1" minOccurs="0" ref="wsnt:Topic"/>
+      <xsd:element maxOccurs="1" minOccurs="0" ref="wsnt:ProducerReference"/>
+      <xsd:element name="Message">
+        <xsd:complexType>
+          <xsd:sequence>
+            <xsd:any maxOccurs="1" minOccurs="1" namespace="##any" processContents="lax"/>
+          </xsd:sequence>
+        </xsd:complexType>
+      </xsd:element>
+    </xsd:sequence>
+  </xsd:complexType>
+  <xsd:element name="NotificationMessage" type="wsnt:NotificationMessageHolderType"/>
+
+<!-- ========== Message Types for NotificationConsumer  =========== -->
+  <xsd:element name="Notify">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:element maxOccurs="unbounded" minOccurs="1" ref="wsnt:NotificationMessage"/>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+
+<!-- ========== Message Types for NotificationProducer  =========== -->
+
+  <xsd:simpleType name="AbsoluteOrRelativeTimeType">
+    <xsd:union memberTypes="xsd:dateTime xsd:duration"/>
+  </xsd:simpleType>
+
+  <xsd:element name="CurrentTime" type="xsd:dateTime"/>
+
+  <xsd:element name="TerminationTime" nillable="true" type="xsd:dateTime"/>
+
+  <xsd:element name="ProducerProperties" type="wsnt:QueryExpressionType"/>
+
+  <xsd:element name="MessageContent" type="wsnt:QueryExpressionType"/>
+
+  <xsd:element name="UseRaw">
+<xsd:complexType/>
+</xsd:element>
+
+  <xsd:element name="Subscribe">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:element maxOccurs="1" minOccurs="1" name="ConsumerReference" type="wsa:EndpointReferenceType"/>
+        <xsd:element maxOccurs="1" minOccurs="0" name="Filter" type="wsnt:FilterType"/>
+        <xsd:element maxOccurs="1" minOccurs="0" name="InitialTerminationTime" nillable="true" type="wsnt:AbsoluteOrRelativeTimeType"/>
+        <xsd:element maxOccurs="1" minOccurs="0" name="SubscriptionPolicy">
+          <xsd:complexType>
+            <xsd:sequence>
+              <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##any" processContents="lax"/>
+            </xsd:sequence>
+          </xsd:complexType>
+        </xsd:element>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+        
+  <xsd:element name="SubscribeResponse">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:element maxOccurs="1" minOccurs="0" name="SubscriptionReference" type="wsa:EndpointReferenceType"/>
+        <xsd:element maxOccurs="1" minOccurs="0" ref="wsnt:CurrentTime"/>
+        <xsd:element maxOccurs="1" minOccurs="0" ref="wsnt:TerminationTime"/>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+                  
+  <xsd:element name="GetCurrentMessage">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:element name="Topic" type="wsnt:TopicExpressionType"/>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:element name="GetCurrentMessageResponse">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:complexType name="SubscribeCreationFailedFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="SubscribeCreationFailedFault" type="wsnt:SubscribeCreationFailedFaultType"/>
+
+  <xsd:complexType name="InvalidFilterFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType">
+        <xsd:sequence>
+          <xsd:element maxOccurs="unbounded" minOccurs="1" name="UnknownFilter" type="xsd:QName"/>
+        </xsd:sequence>
+      </xsd:extension>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="InvalidFilterFault" type="wsnt:InvalidFilterFaultType"/>
+
+  <xsd:complexType name="TopicExpressionDialectUnknownFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="TopicExpressionDialectUnknownFault" type="wsnt:TopicExpressionDialectUnknownFaultType"/>
+
+  <xsd:complexType name="InvalidTopicExpressionFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="InvalidTopicExpressionFault" type="wsnt:InvalidTopicExpressionFaultType"/>
+
+  <xsd:complexType name="TopicNotSupportedFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="TopicNotSupportedFault" type="wsnt:TopicNotSupportedFaultType"/>
+
+  <xsd:complexType name="MultipleTopicsSpecifiedFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="MultipleTopicsSpecifiedFault" type="wsnt:MultipleTopicsSpecifiedFaultType"/>
+
+  <xsd:complexType name="InvalidProducerPropertiesExpressionFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="InvalidProducerPropertiesExpressionFault" type="wsnt:InvalidProducerPropertiesExpressionFaultType"/>
+
+  <xsd:complexType name="InvalidMessageContentExpressionFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="InvalidMessageContentExpressionFault" type="wsnt:InvalidMessageContentExpressionFaultType"/>
+
+  <xsd:complexType name="InvalidUseRawValueFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="InvalidUseRawValueFault" type="wsnt:InvalidUseRawValueFaultType"/>
+
+  <xsd:complexType name="UnacceptableInitialTerminationTimeFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType">
+        <xsd:sequence>
+          <xsd:element name="MinimumTime" type="xsd:dateTime"/>
+          <xsd:element minOccurs="0" name="MaximumTime" type="xsd:dateTime"/>
+        </xsd:sequence>
+      </xsd:extension>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="UnacceptableInitialTerminationTimeFault" type="wsnt:UnacceptableInitialTerminationTimeFaultType"/>
+
+  <xsd:complexType name="NoCurrentMessageOnTopicFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="NoCurrentMessageOnTopicFault" type="wsnt:NoCurrentMessageOnTopicFaultType"/>
+
+<!-- ======== Message Types for PullPoint  ======================== -->
+  <xsd:element name="GetMessages">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:element name="MaximumNumber" type="xsd:nonNegativeInteger"/>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+      <xsd:anyAttribute/>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:element name="GetMessagesResponse">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:element maxOccurs="unbounded" minOccurs="0" ref="wsnt:NotificationMessage"/>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+      <xsd:anyAttribute/>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:element name="Destroy">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+      <xsd:anyAttribute/>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:element name="DestroyResponse">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+      <xsd:anyAttribute/>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:complexType name="UnableToDestroyPullPointType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="UnableToDestroyPullPoint" type="wsnt:UnableToDestroyPullPointType"/>
+
+<!-- ======== Message Types for Create PullPoint  ================= -->
+  <xsd:element name="CreatePullPoint">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+      <xsd:anyAttribute/>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:element name="CreatePullPointResponse">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:element name="PullPoint" type="wsa:EndpointReferenceType"/>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+      <xsd:anyAttribute/>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:complexType name="UnableToCreatePullPointType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="UnableToCreatePullPoint" type="wsnt:UnableToCreatePullPointType"/>
+
+<!-- ======== Message Types for Base SubscriptionManager  ========= -->
+  <xsd:element name="Renew">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:element maxOccurs="1" minOccurs="1" name="TerminationTime" nillable="true" type="wsnt:AbsoluteOrRelativeTimeType"/>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:element name="RenewResponse">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:element maxOccurs="1" minOccurs="1" ref="wsnt:TerminationTime"/>
+        <xsd:element maxOccurs="1" minOccurs="0" ref="wsnt:CurrentTime"/>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:complexType name="UnacceptableTerminationTimeFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType">
+        <xsd:sequence>
+          <xsd:element name="MinimumTime" type="xsd:dateTime"/>
+          <xsd:element minOccurs="0" name="MaximumTime" type="xsd:dateTime"/>
+        </xsd:sequence>
+      </xsd:extension>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="UnacceptableTerminationTimeFault" type="wsnt:UnacceptableTerminationTimeFaultType"/>
+
+  <xsd:element name="Unsubscribe">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:element name="UnsubscribeResponse">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:complexType name="UnableToDestroySubscriptionFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="UnableToDestroySubscriptionFault" type="wsnt:UnableToDestroySubscriptionFaultType"/>
+
+<!-- ====== Message Types for Pausable SubscriptionManager  ======= -->
+
+  <xsd:element name="PauseSubscription">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:element name="PauseSubscriptionResponse">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:element name="ResumeSubscription">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:element name="ResumeSubscriptionResponse">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:complexType name="PauseFailedFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="PauseFailedFault" type="wsnt:PauseFailedFaultType"/>
+
+  <xsd:complexType name="ResumeFailedFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="ResumeFailedFault" type="wsnt:ResumeFailedFaultType"/>
+
+</xsd:schema>

Added: incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/bf-1.xsd
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/bf-1.xsd?rev=357814&view=auto
==============================================================================
--- incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/bf-1.xsd (added)
+++ incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/bf-1.xsd Mon Dec 19 14:08:30 2005
@@ -0,0 +1,66 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!-- 
+   OASIS takes no position regarding the validity or scope of any intellectual property or other rights that might be claimed to pertain to the implementation or use of the technology described in this document or the extent to which any license under such rights might or might not be available; neither does it represent that it has made any effort to identify any such rights. Information on OASIS's procedures with respect to rights in OASIS specifications can be found at the OASIS website. Copies of claims of rights made available for publication and any assurances of licenses to be made available, or the result of an attempt made to obtain a general license or permission for the use of such proprietary rights by implementers or users of this specification, can be obtained from the OASIS Executive Director. 
+
+OASIS invites any interested party to bring to its attention any copyrights, patents or patent applications, or other proprietary rights which may cover technology that may be required to implement this specification. Please address the information to the OASIS Executive Director. 
+
+Copyright (C) OASIS Open (2005). All Rights Reserved. 
+
+This document and translations of it may be copied and furnished to others, and derivative works that comment on or otherwise explain it or assist in its implementation may be prepared, copied, published and distributed, in whole or in part, without restriction of any kind, provided that the above copyright notice and this paragraph are included on all such copies and derivative works. However, this document itself may not be modified in any way, such as by removing the copyright notice or references to OASIS, except as needed for the purpose of developing OASIS specifications, in which case the procedures for copyrights defined in the OASIS Intellectual Property Rights document must be followed, or as required to translate it into languages other than English. 
+
+The limited permissions granted above are perpetual and will not be revoked by OASIS or its successors or assigns. 
+
+This document and the information contained herein is provided on an "AS IS" basis and OASIS DISCLAIMS ALL WARRANTIES, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO ANY WARRANTY THAT THE USE OF THE INFORMATION HEREIN WILL NOT INFRINGE ANY RIGHTS OR ANY IMPLIED WARRANTIES OF MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE. 
+-->
+<xsd:schema xmlns="http://www.w3.org/2001/XMLSchema" xmlns:wsa="http://www.w3.org/2005/03/addressing" xmlns:wsrf-bf="http://docs.oasis-open.org/wsrf/bf-1" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" attributeFormDefault="unqualified" elementFormDefault="qualified" targetNamespace="http://docs.oasis-open.org/wsrf/bf-1">
+  <xsd:import namespace="http://www.w3.org/2005/03/addressing" schemaLocation="wsa.xsd"/>
+   
+              
+  <xsd:import namespace="http://www.w3.org/XML/1998/namespace" schemaLocation="xml.xsd">
+    <xsd:annotation>
+      <xsd:documentation>
+        Get access to the xml: attribute groups for xml:lang as declared on 'schema'
+        and 'documentation' below
+      </xsd:documentation> 
+    </xsd:annotation>
+  </xsd:import>
+<!-- ====================== BaseFault Types ======================= -->
+      
+  <xsd:element name="BaseFault" type="wsrf-bf:BaseFaultType"/>
+  
+  <xsd:complexType name="BaseFaultType">
+    <xsd:sequence>
+      <xsd:element maxOccurs="1" minOccurs="1" name="Timestamp" type="xsd:dateTime"/>
+      <xsd:element maxOccurs="1" minOccurs="0" name="Originator" type="wsa:EndpointReferenceType"/>
+      <xsd:element maxOccurs="1" minOccurs="0" name="ErrorCode">
+        <xsd:complexType>
+          <xsd:complexContent mixed="true">
+            <xsd:extension base="xsd:anyType">
+              <xsd:attribute name="dialect" type="xsd:anyURI" use="required"/>
+            </xsd:extension>
+          </xsd:complexContent>
+        </xsd:complexType>      
+      </xsd:element>
+
+      <xsd:element maxOccurs="unbounded" minOccurs="0" name="Description">
+        <xsd:complexType>
+          <xsd:simpleContent>
+            <xsd:extension base="xsd:string">
+              <xsd:attribute ref="xml:lang" use="optional"/>
+            </xsd:extension>
+          </xsd:simpleContent>
+        </xsd:complexType>
+      </xsd:element>
+      <xsd:element maxOccurs="1" minOccurs="0" name="FaultCause">
+        <xsd:complexType>
+          <xsd:sequence>
+            <xsd:any maxOccurs="1" minOccurs="1" namespace="##other" processContents="lax"/>
+          </xsd:sequence>
+        </xsd:complexType> 
+      </xsd:element>
+
+      <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+    </xsd:sequence>
+    <xsd:anyAttribute namespace="##other" processContents="lax"/>
+ </xsd:complexType>
+</xsd:schema>

Added: incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/br-1.xsd
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/br-1.xsd?rev=357814&view=auto
==============================================================================
--- incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/br-1.xsd (added)
+++ incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/br-1.xsd Mon Dec 19 14:08:30 2005
@@ -0,0 +1,133 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!-- 
+OASIS takes no position regarding the validity or scope of any intellectual property or other rights that might be claimed to pertain to the implementation or use of the technology described in this document or the extent to which any license under such rights might or might not be available; neither does it represent that it has made any effort to identify any such rights. Information on OASIS's procedures with respect to rights in OASIS specifications can be found at the OASIS website. Copies of claims of rights made available for publication and any assurances of licenses to be made available, or the result of an attempt made to obtain a general license or permission for the use of such proprietary rights by implementors or users of this specification, can be obtained from the OASIS Executive Director.
+
+OASIS invites any interested party to bring to its attention any copyrights, patents or patent applications, or other proprietary rights which may cover technology that may be required to implement this specification. Please address the information to the OASIS Executive Director.
+
+Copyright (C) OASIS Open (2005). All Rights Reserved.
+
+This document and translations of it may be copied and furnished to others, and derivative works that comment on or otherwise explain it or assist in its implementation may be prepared, copied, published and distributed, in whole or in part, without restriction of any kind, provided that the above copyright notice and this paragraph are included on all such copies and derivative works. However, this document itself may not be modified in any way, such as by removing the copyright notice or references to OASIS, except as needed for the purpose of developing OASIS specifications, in which case the procedures for copyrights defined in the OASIS Intellectual Property Rights document must be followed, or as required to translate it into languages other than English. 
+
+The limited permissions granted above are perpetual and will not be revoked by OASIS or its successors or assigns. 
+
+This document and the information contained herein is provided on an "AS IS" basis and OASIS DISCLAIMS ALL WARRANTIES, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO ANY WARRANTY THAT THE USE OF THE INFORMATION HEREIN WILL NOT INFRINGE ANY RIGHTS OR ANY IMPLIED WARRANTIES OF MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE.
+-->
+<xsd:schema xmlns="http://www.w3.org/2001/XMLSchema" xmlns:wsa="http://www.w3.org/2005/03/addressing" xmlns:wsn-b="http://docs.oasis-open.org/wsn/b-1" xmlns:wsn-br="http://docs.oasis-open.org/wsn/br-1" xmlns:wsrf-bf="http://docs.oasis-open.org/wsrf/bf-1" xmlns:xsd="http://www.w3.org/2001/XMLSchema" attributeFormDefault="unqualified" elementFormDefault="qualified" targetNamespace="http://docs.oasis-open.org/wsn/br-1">
+
+<!-- ======================== Imports  ============================ -->
+  
+  <xsd:import namespace="http://www.w3.org/2005/03/addressing" schemaLocation="wsa.xsd"/>
+
+  <xsd:import namespace="http://docs.oasis-open.org/wsrf/bf-1" schemaLocation="bf-1.xsd"/>
+
+  <xsd:import namespace="http://docs.oasis-open.org/wsn/b-1" schemaLocation="b-1.xsd"/>
+
+<!-- ======== Resource Properties for NotificationBroker ========== -->
+   <xsd:element name="RequiresRegistration" type="xsd:boolean"/>         
+
+<!-- ====== Resource Properties for PublisherRegistration ========= -->
+   <xsd:element name="PublisherReference" type="wsa:EndpointReferenceType"/>
+   <xsd:element name="Topic" type="wsn-b:TopicExpressionType"/>
+   <xsd:element name="Demand" type="xsd:boolean"/>
+   <xsd:element name="CreationTime" type="xsd:dateTime"/>
+<xsd:element name="NotificationBrokerRP">
+            <xsd:complexType>
+               <xsd:sequence>
+         <!-- From NotificationProducer -->
+                  <xsd:element maxOccurs="unbounded" minOccurs="0" ref="wsn-b:TopicExpression"/>
+        		  <xsd:element maxOccurs="1" minOccurs="0" ref="wsn-b:FixedTopicSet"/>
+        		  <xsd:element maxOccurs="unbounded" minOccurs="0" ref="wsn-b:TopicExpressionDialect"/>
+
+         <!-- NotificationBroker specific  -->
+                  <xsd:element maxOccurs="1" minOccurs="1" ref="wsn-br:RequiresRegistration"/>        
+               </xsd:sequence>
+            </xsd:complexType>
+   </xsd:element>
+ 
+<!-- ====== Resource Properties for PublisherRegistration ========= -->
+   <xsd:element name="PublisherRegistrationRP">
+            <xsd:complexType>
+               <xsd:sequence>
+         <!-- From WS-ResourceLifetime ScheduledResourceTermination -->
+                  <xsd:element maxOccurs="1" minOccurs="0" ref="wsn-b:CurrentTime"/> 
+                  <xsd:element maxOccurs="1" minOccurs="1" ref="wsn-b:TerminationTime"/>
+                               
+         <!-- PublisherRegistration specific  -->
+                  <xsd:element maxOccurs="1" minOccurs="0" ref="wsn-br:PublisherReference"/>
+                  <xsd:element maxOccurs="unbounded" minOccurs="0" ref="wsn-br:Topic"/>
+                  <xsd:element maxOccurs="1" minOccurs="1" ref="wsn-br:Demand"/>
+                  <xsd:element maxOccurs="1" minOccurs="0" ref="wsn-br:CreationTime"/>
+               </xsd:sequence>
+            </xsd:complexType>
+   </xsd:element>
+
+<!-- ========== Message Types for NotificationBroker  ============ -->
+   <xsd:element name="RegisterPublisher">
+            <xsd:complexType>
+               <xsd:sequence>
+                  <xsd:element maxOccurs="1" minOccurs="0" name="PublisherReference" type="wsa:EndpointReferenceType"/>
+                  <xsd:element maxOccurs="unbounded" minOccurs="0" name="Topic" type="wsn-b:TopicExpressionType"/>
+                  <xsd:element default="false" maxOccurs="1" minOccurs="0" name="Demand" type="xsd:boolean"/>
+                  <xsd:element maxOccurs="1" minOccurs="0" name="InitialTerminationTime" type="xsd:dateTime"/>
+                  <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+               </xsd:sequence>
+            </xsd:complexType>
+   </xsd:element>
+
+   <xsd:element name="RegisterPublisherResponse"> 
+            <xsd:complexType>
+               <xsd:sequence>
+                  <xsd:element maxOccurs="1" minOccurs="0" name="PublisherRegistrationReference" type="wsa:EndpointReferenceType"/>
+               </xsd:sequence>
+            </xsd:complexType>
+   </xsd:element>
+
+   
+   
+   <xsd:complexType name="PublisherRegistrationRejectedFaultType">
+            <xsd:complexContent>
+               <xsd:extension base="wsrf-bf:BaseFaultType"/>
+            </xsd:complexContent>
+         </xsd:complexType>
+   <xsd:element name="PublisherRegistrationRejectedFault" type="wsn-br:PublisherRegistrationRejectedFaultType"/>
+   
+   <xsd:complexType name="PublisherRegistrationFailedFaultType">
+            <xsd:complexContent>
+               <xsd:extension base="wsrf-bf:BaseFaultType"/>
+            </xsd:complexContent>
+         </xsd:complexType>
+   <xsd:element name="PublisherRegistrationFailedFault" type="wsn-br:PublisherRegistrationFailedFaultType"/>
+
+  <xsd:complexType name="PullNotificationNotSupportedType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="PullNotificationNotSupportedFault" type="wsn-br:PullNotificationNotSupportedType"/>
+
+   <xsd:element name="Destroy">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+      <xsd:anyAttribute/>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:element name="DestroyResponse">
+    <xsd:complexType>
+      <xsd:sequence>
+        <xsd:any maxOccurs="unbounded" minOccurs="0" namespace="##other" processContents="lax"/>
+      </xsd:sequence>
+      <xsd:anyAttribute/>
+    </xsd:complexType>
+  </xsd:element>
+
+  <xsd:complexType name="ResourceNotDestroyedFaultType">
+    <xsd:complexContent>
+      <xsd:extension base="wsrf-bf:BaseFaultType"/>
+    </xsd:complexContent>
+  </xsd:complexType>
+  <xsd:element name="ResourceNotDestroyedFault" type="wsn-br:ResourceNotDestroyedFaultType"/>
+
+ </xsd:schema>

Added: incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/brw-1.wsdl
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/brw-1.wsdl?rev=357814&view=auto
==============================================================================
--- incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/brw-1.wsdl (added)
+++ incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/brw-1.wsdl Mon Dec 19 14:08:30 2005
@@ -0,0 +1,214 @@
+<?xml version="1.0" encoding="utf-8"?>
+<!-- 
+OASIS takes no position regarding the validity or scope of any intellectual property or other rights that might be claimed to pertain to the implementation or use of the technology described in this document or the extent to which any license under such rights might or might not be available; neither does it represent that it has made any effort to identify any such rights. Information on OASIS's procedures with respect to rights in OASIS specifications can be found at the OASIS website. Copies of claims of rights made available for publication and any assurances of licenses to be made available, or the result of an attempt made to obtain a general license or permission for the use of such proprietary rights by implementors or users of this specification, can be obtained from the OASIS Executive Director.
+
+OASIS invites any interested party to bring to its attention any copyrights, patents or patent applications, or other proprietary rights which may cover technology that may be required to implement this specification. Please address the information to the OASIS Executive Director.
+
+Copyright (C) OASIS Open (2005). All Rights Reserved.
+
+This document and translations of it may be copied and furnished to others, and derivative works that comment on or otherwise explain it or assist in its implementation may be prepared, copied, published and distributed, in whole or in part, without restriction of any kind, provided that the above copyright notice and this paragraph are included on all such copies and derivative works. However, this document itself may not be modified in any way, such as by removing the copyright notice or references to OASIS, except as needed for the purpose of developing OASIS specifications, in which case the procedures for copyrights defined in the OASIS Intellectual Property Rights document must be followed, or as required to translate it into languages other than English. 
+
+The limited permissions granted above are perpetual and will not be revoked by OASIS or its successors or assigns. 
+
+This document and the information contained herein is provided on an "AS IS" basis and OASIS DISCLAIMS ALL WARRANTIES, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO ANY WARRANTY THAT THE USE OF THE INFORMATION HEREIN WILL NOT INFRINGE ANY RIGHTS OR ANY IMPLIED WARRANTIES OF MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE.
+-->
+
+<wsdl:definitions name="WS-BrokeredNotification"
+  xmlns="http://schemas.xmlsoap.org/wsdl/"
+  xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/"
+  xmlns:xsd="http://www.w3.org/2001/XMLSchema" 
+  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xmlns:wsa="http://www.w3.org/2005/03/addressing"
+  xmlns:wsn-br="http://docs.oasis-open.org/wsn/br-1" 
+  xmlns:wsn-brw="http://docs.oasis-open.org/wsn/brw-1"
+  xmlns:wsn-b="http://docs.oasis-open.org/wsn/b-1"
+  xmlns:wsn-bw="http://docs.oasis-open.org/wsn/bw-1"
+  xmlns:wsrf-bf="http://docs.oasis-open.org/wsrf/bf-1"   
+  xmlns:wsrf-rw="http://docs.oasis-open.org/wsrf/rw-1" 
+  targetNamespace="http://docs.oasis-open.org/wsn/brw-1">
+
+<!-- ========================== Imports =========================== -->
+<wsdl:import namespace="http://docs.oasis-open.org/wsrf/rw-1" 
+       location="rw-1.wsdl"/>
+       
+   <wsdl:import namespace="http://docs.oasis-open.org/wsn/bw-1" 
+       location="bw-1.wsdl"/>
+
+<!-- ===================== Types Definitions ====================== -->
+   <wsdl:types>
+     <xsd:schema>
+       <xsd:import
+         namespace="http://docs.oasis-open.org/wsn/br-1" 
+         schemaLocation="br-1.xsd"/>
+     </xsd:schema>
+   </wsdl:types>
+
+<!-- ========== NotificationBroker::RegisterPublisher =============
+   RegisterPublisher(PublisherReference, TopicExpression* ,
+                     [Demand], [InitialTerminationTime])
+   returns: WS-Resource qualified EPR to a PublisherRegistration --> 
+   <wsdl:message name="RegisterPublisherRequest">
+      <wsdl:part name="RegisterPublisherRequest" 
+                 element="wsn-br:RegisterPublisher"/>
+   </wsdl:message>
+
+   <wsdl:message name="RegisterPublisherResponse">
+      <wsdl:part name="RegisterPublisherResponse" 
+                 element="wsn-br:RegisterPublisherResponse"/>
+   </wsdl:message>
+      
+   <wsdl:message name="InvalidTopicExpressionFault">
+      <wsdl:part name="InvalidTopicExpressionFault"
+            element="wsn-b:InvalidTopicExpressionFault" />
+   </wsdl:message> 
+
+   <wsdl:message name="TopicNotSupportedFault">
+      <wsdl:part name="TopicNotSupportedFault"
+            element="wsn-b:TopicNotSupportedFault" />
+   </wsdl:message> 
+
+   <wsdl:message name="PublisherRegistrationRejectedFault">
+      <wsdl:part name="PublisherRegistrationRejectedFault"             
+            element="wsn-br:PublisherRegistrationRejectedFault"/>
+   </wsdl:message> 
+
+   <wsdl:message name="PublisherRegistrationFailedFault">
+      <wsdl:part name="PublisherRegistrationFailedFault"
+            element="wsn-br:PublisherRegistrationFailedFault"/>
+   </wsdl:message> 
+
+   <wsdl:message name="PullNotificationNotSupportedFault">
+      <wsdl:part name="PullNotificationNotSupportedFault"
+            element="wsn-br:PullNotificationNotSupportedFault"/>
+   </wsdl:message> 
+
+   <wsdl:message name="DestroyRequest">
+      <wsdl:part name="DestroyRequest" 
+            element="wsn-br:Destroy"/>
+   </wsdl:message>
+
+   <wsdl:message name="DestroyResponse">
+      <wsdl:part name="DestroyResponse"
+            element="wsn-br:DestroyResponse"/>
+   </wsdl:message>
+
+   <wsdl:message name="ResourceNotDestroyedFault">
+      <wsdl:part name="ResourceNotDestroyedFault"
+            element="wsn-br:ResourceNotDestroyedFault"/>
+   </wsdl:message> 
+
+<!-- =================== PortType Definitions ===================== -->
+
+<!-- ========== RegisterPublisher ============ -->
+<wsdl:portType name="RegisterPublisher">
+    <wsdl:operation name="RegisterPublisher">
+         <wsdl:input  message="wsn-brw:RegisterPublisherRequest"/>
+         <wsdl:output message="wsn-brw:RegisterPublisherResponse"/>
+         <wsdl:fault  name="ResourceUnknownFault"
+                      message="wsrf-rw:ResourceUnknownFault"/>
+         <wsdl:fault  name="InvalidTopicExpressionFault" 
+                      message="wsn-brw:InvalidTopicExpressionFault"/>
+         <wsdl:fault  name="TopicNotSupportedFault" 
+                      message="wsn-brw:TopicNotSupportedFault"/>
+         <wsdl:fault  name="PublisherRegistrationRejectedFault" 
+                 message="wsn-brw:PublisherRegistrationRejectedFault"/>
+	     <wsdl:fault  name="PublisherRegistrationFailedFault" 
+                 message="wsn-brw:PublisherRegistrationFailedFault"/>
+    </wsdl:operation>
+  </wsdl:portType>
+
+
+<!-- ========== NotificationBroker PortType Definition ============ -->
+   <wsdl:portType name="NotificationBroker">
+      <!-- ============= extends NotificationConsumer ============= -->
+      <wsdl:operation name="Notify">
+         <wsdl:input message="wsn-bw:Notify" />
+      </wsdl:operation>
+      
+      <!-- ============= extends NotificationProducer ============= -->
+      <wsdl:operation name="Subscribe">
+         <wsdl:input  message="wsn-bw:SubscribeRequest" />
+         <wsdl:output message="wsn-bw:SubscribeResponse" />
+         <wsdl:fault  name="ResourceUnknownFault" 
+                      message="wsrf-rw:ResourceUnknownFault" />
+         <wsdl:fault  name="InvalidFilterFault" 
+                   message="wsn-bw:InvalidFilterFault"/>
+         <wsdl:fault  name="TopicExpressionDialectUnknownFault" 
+                   message="wsn-bw:TopicExpressionDialectUnknownFault"/>
+         <wsdl:fault  name="InvalidTopicExpressionFault" 
+                      message="wsn-bw:InvalidTopicExpressionFault" />
+         <wsdl:fault  name="TopicNotSupportedFault" 
+                      message="wsn-bw:TopicNotSupportedFault" />
+         <wsdl:fault  name="InvalidProducerPropertiesExpressionFault" 
+             message="wsn-bw:InvalidProducerPropertiesExpressionFault"/>
+         <wsdl:fault  name="InvalidMessageContentExpressionFault" 
+             message="wsn-bw:InvalidMessageContentExpressionFault"/>
+         <wsdl:fault  name="InvalidUseRawValueFault" 
+             message="wsn-bw:InvalidUseRawValueFault"/>
+         <wsdl:fault  name="UnacceptableInitialTerminationTimeFault" 
+             message="wsn-bw:UnacceptableInitialTerminationTimeFault"/>
+         <wsdl:fault  name="SubscribeCreationFailedFault" 
+                      message="wsn-bw:SubscribeCreationFailedFault"/>
+      </wsdl:operation>
+      <wsdl:operation name="GetCurrentMessage">
+         <wsdl:input  message="wsn-bw:GetCurrentMessageRequest"/>
+         <wsdl:output message="wsn-bw:GetCurrentMessageResponse"/>
+         <wsdl:fault  name="ResourceUnknownFault" 
+                      message="wsrf-rw:ResourceUnknownFault"/>
+         <wsdl:fault  name="TopicExpressionDialectUnknownFault" 
+                  message="wsn-bw:TopicExpressionDialectUnknownFault"/>
+         <wsdl:fault  name="InvalidTopicExpressionFault" 
+                      message="wsn-bw:InvalidTopicExpressionFault"/>
+         <wsdl:fault  name="TopicNotSupportedFault" 
+                      message="wsn-bw:TopicNotSupportedFault"/>
+         <wsdl:fault  name="NoCurrentMessageOnTopicFault" 
+                      message="wsn-bw:NoCurrentMessageOnTopicFault"/>
+         <wsdl:fault  name="MultipleTopicsSpecifiedFault" 
+                      message="wsn-bw:MultipleTopicsSpecifiedFault"/>
+      </wsdl:operation>
+      
+      <!-- ========= extends RegisterPublisher ======= -->      
+      <wsdl:operation name="RegisterPublisher">
+         <wsdl:input  message="wsn-brw:RegisterPublisherRequest"/>
+         <wsdl:output message="wsn-brw:RegisterPublisherResponse"/>
+         <wsdl:fault  name="ResourceUnknownFault" 
+                      message="wsrf-rw:ResourceUnknownFault"/>
+         <wsdl:fault  name="InvalidTopicExpressionFault" 
+                      message="wsn-brw:InvalidTopicExpressionFault"/>
+         <wsdl:fault  name="TopicNotSupportedFault" 
+                      message="wsn-brw:TopicNotSupportedFault"/>
+         <wsdl:fault  name="PublisherRegistrationRejectedFault" 
+                 message="wsn-brw:PublisherRegistrationRejectedFault"/>
+         <wsdl:fault  name="PublisherRegistrationFailedFault" 
+                   message="wsn-brw:PublisherRegistrationFailedFault"/>
+      </wsdl:operation>
+
+      <!-- ========= extends CreatePullPoint ======= -->      
+   <wsdl:operation name="CreatePullPoint">
+         <wsdl:input  name="CreatePullPointRequest" 
+                      message="wsn-bw:CreatePullPointRequest" />
+         <wsdl:output name="CreatePullPointResponse" 
+                      message="wsn-bw:CreatePullPointResponse" />
+         <wsdl:fault  name="UnableToCreatePullPoint" 
+                      message="wsn-bw:UnableToCreatePullPoint" />
+         <wsdl:fault  name="PullNotificationNotSupportedFault" 
+                  message="wsn-brw:PullNotificationNotSupportedFault"/>
+      </wsdl:operation>
+   </wsdl:portType>
+
+<!-- ===== PublisherRegistrationManager PortType Definition ====== -->
+   <wsdl:portType name="PublisherRegistrationManager">
+      
+   <!-- === Destroy:ImmediateResourceTermination========== -->
+      <wsdl:operation name="Destroy">
+         <wsdl:input  name="DestroyRequest" 
+                      message="wsn-brw:DestroyRequest" />
+         <wsdl:output name="DestroyResponse" 
+                      message="wsn-brw:DestroyResponse" />
+      <wsdl:fault name="ResourceUnknownFault"
+                message="wsrf-rw:ResourceUnknownFault" />
+         <wsdl:fault  name="ResourceNotDestroyedFault" 
+                      message="wsn-brw:ResourceNotDestroyedFault" />
+      </wsdl:operation>
+   </wsdl:portType>
+</wsdl:definitions>

Added: incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/bw-1.wsdl
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/bw-1.wsdl?rev=357814&view=auto
==============================================================================
--- incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/bw-1.wsdl (added)
+++ incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/bw-1.wsdl Mon Dec 19 14:08:30 2005
@@ -0,0 +1,278 @@
+<?xml version="1.0" encoding="utf-8"?>
+<!-- edited with XMLSPY v2004 rel. 4 U (http://www.xmlspy.com) by Altova XMLSPY 2004 Enterprise Ed. Release 4 (W3C) -->
+<!-- 
+
+OASIS takes no position regarding the validity or scope of any intellectual property or other rights that might be claimed to pertain to the implementation or use of the technology described in this document or the extent to which any license under such rights might or might not be available; neither does it represent that it has made any effort to identify any such rights. Information on OASIS's procedures with respect to rights in OASIS specifications can be found at the OASIS website. Copies of claims of rights made available for publication and any assurances of licenses to be made available, or the result of an attempt made to obtain a general license or permission for the use of such proprietary rights by implementors or users of this specification, can be obtained from the OASIS Executive Director.
+
+OASIS invites any interested party to bring to its attention any copyrights, patents or patent applications, or other proprietary rights which may cover technology that may be required to implement this specification. Please address the information to the OASIS Executive Director.
+
+Copyright (C) OASIS Open (2004-2005). All Rights Reserved.
+
+This document and translations of it may be copied and furnished to others, and derivative works that comment on or otherwise explain it or assist in its implementation may be prepared, copied, published and distributed, in whole or in part, without restriction of any kind, provided that the above copyright notice and this paragraph are included on all such copies and derivative works. However, this document itself may not be modified in any way, such as by removing the copyright notice or references to OASIS, except as needed for the purpose of developing OASIS specifications, in which case the procedures for copyrights defined in the OASIS Intellectual Property Rights document must be followed, or as required to translate it into languages other than English. 
+
+The limited permissions granted above are perpetual and will not be revoked by OASIS or its successors or assigns. 
+
+This document and the information contained herein is provided on an "AS IS" basis and OASIS DISCLAIMS ALL WARRANTIES, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO ANY WARRANTY THAT THE USE OF THE INFORMATION HEREIN WILL NOT INFRINGE ANY RIGHTS OR ANY IMPLIED WARRANTIES OF MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE.
+
+-->
+<wsdl:definitions name="WS-BaseNotification" targetNamespace="http://docs.oasis-open.org/wsn/bw-1" xmlns:wsntw="http://docs.oasis-open.org/wsn/bw-1" xmlns:wsnt="http://docs.oasis-open.org/wsn/b-1" xmlns:wsa="http://www.w3.org/2005/03/addressing" xmlns:wsrf-rw="http://docs.oasis-open.org/wsrf/rw-1" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/">
+	<!-- ========================== Imports =========================== -->
+	<wsdl:import namespace="http://docs.oasis-open.org/wsrf/rw-1" location="rw-1.wsdl"/>
+	<!-- ===================== Types Definitions ====================== -->
+	<wsdl:types>
+		<xsd:schema>
+			<xsd:import namespace="http://docs.oasis-open.org/wsn/b-1" schemaLocation="b-1.xsd"/>
+		</xsd:schema>
+	</wsdl:types>
+	<!-- ================ NotificationConsumer::Notify ================ 
+  Notify(
+    NotificationMessage
+      (SubscriptionReference, TopicExpression, ProducerReference,
+       Message)*
+  returns: n/a (one way)
+-->
+	<wsdl:message name="Notify">
+		<wsdl:part name="Notify" element="wsnt:Notify"/>
+	</wsdl:message>
+	<!-- ============== NotificationProducer::Subscribe =============== 
+  Subscribe(
+   (ConsumerEndpointReference, [Filter], [SubscriptionPolicy], 
+   [InitialTerminationTime])   
+  returns: WS-Resource qualified EPR to a Subscription
+-->
+	<wsdl:message name="SubscribeRequest">
+		<wsdl:part name="SubscribeRequest" element="wsnt:Subscribe"/>
+	</wsdl:message>
+	<wsdl:message name="SubscribeResponse">
+		<wsdl:part name="SubscribeResponse" element="wsnt:SubscribeResponse"/>
+	</wsdl:message>
+	<wsdl:message name="SubscribeCreationFailedFault">
+		<wsdl:part name="SubscribeCreationFailedFault" element="wsnt:SubscribeCreationFailedFault"/>
+	</wsdl:message>
+	<wsdl:message name="TopicExpressionDialectUnknownFault">
+		<wsdl:part name="TopicExpressionDialectUnknownFault" element="wsnt:TopicExpressionDialectUnknownFault"/>
+	</wsdl:message>
+	<wsdl:message name="InvalidFilterFault">
+		<wsdl:part name="InvalidFilterFault" element="wsnt:InvalidFilterFault"/>
+	</wsdl:message>
+	<wsdl:message name="InvalidProducerPropertiesExpressionFault">
+		<wsdl:part name="InvalidProducerPropertiesExpressionFault" element="wsnt:InvalidProducerPropertiesExpressionFault"/>
+	</wsdl:message>
+	<wsdl:message name="InvalidMessageContentExpressionFault">
+		<wsdl:part name="InvalidMessageContentExpressionFault" element="wsnt:InvalidMessageContentExpressionFault"/>
+	</wsdl:message>
+	<wsdl:message name="InvalidUseRawValueFault">
+		<wsdl:part name="InvalidUseRawValueFault" element="wsnt:InvalidUseRawValueFault"/>
+	</wsdl:message>
+	<wsdl:message name="UnacceptableInitialTerminationTimeFault">
+		<wsdl:part name="UnacceptableInitialTerminationTimeFault" element="wsnt:UnacceptableInitialTerminationTimeFault"/>
+	</wsdl:message>
+	<!-- ========== NotificationProducer::GetCurrentMessage =========== 
+  GetCurrentMessage(topicExpression)
+  returns: a NotificationMessage (xsd:any)
+-->
+	<wsdl:message name="GetCurrentMessageRequest">
+		<wsdl:part name="GetCurrentMessageRequest" element="wsnt:GetCurrentMessage"/>
+	</wsdl:message>
+	<wsdl:message name="GetCurrentMessageResponse">
+		<wsdl:part name="GetCurrentMessageResponse" element="wsnt:GetCurrentMessageResponse"/>
+	</wsdl:message>
+	<wsdl:message name="InvalidTopicExpressionFault">
+		<wsdl:part name="InvalidTopicExpressionFault" element="wsnt:InvalidTopicExpressionFault"/>
+	</wsdl:message>
+	<wsdl:message name="TopicNotSupportedFault">
+		<wsdl:part name="TopicNotSupportedFault" element="wsnt:TopicNotSupportedFault"/>
+	</wsdl:message>
+	<wsdl:message name="MultipleTopicsSpecifiedFault">
+		<wsdl:part name="MultipleTopicsSpecifiedFault" element="wsnt:MultipleTopicsSpecifiedFault"/>
+	</wsdl:message>
+	<wsdl:message name="NoCurrentMessageOnTopicFault">
+		<wsdl:part name="NoCurrentMessageOnTopicFault" element="wsnt:NoCurrentMessageOnTopicFault"/>
+	</wsdl:message>
+	<!-- ========== PullPoint::GetMessages =========== 
+  GetMessages(MaximumNumber)
+  returns: NotificationMessage list
+-->
+	<wsdl:message name="GetMessagesRequest">
+		<wsdl:part name="GetMessagesRequest" element="wsnt:GetMessages"/>
+	</wsdl:message>
+	<wsdl:message name="GetMessagesResponse">
+		<wsdl:part name="GetMessagesResponse" element="wsnt:GetMessagesResponse"/>
+	</wsdl:message>
+	<!-- ========== PullPoint::Destroy =========== 
+  Destroy()
+  returns: void
+-->
+	<wsdl:message name="DestroyRequest">
+		<wsdl:part name="DestroyRequest" element="wsnt:Destroy"/>
+	</wsdl:message>
+	<wsdl:message name="DestroyResponse">
+		<wsdl:part name="DestroyResponse" element="wsnt:DestroyResponse"/>
+	</wsdl:message>
+	<wsdl:message name="UnableToDestroyPullPoint">
+		<wsdl:part name="UnableToDestroyPullPoint" element="wsnt:UnableToDestroyPullPoint"/>
+	</wsdl:message>
+	<!-- ========== PullPoint::CreatePullPoint =========== 
+  CreatePullPoint()
+  returns: PullPoint (wsa:EndpointReference)
+-->
+	<wsdl:message name="CreatePullPointRequest">
+		<wsdl:part name="CreatePullPointRequest" element="wsnt:CreatePullPoint"/>
+	</wsdl:message>
+	<wsdl:message name="CreatePullPointResponse">
+		<wsdl:part name="CreatePullPointResponse" element="wsnt:CreatePullPointResponse"/>
+	</wsdl:message>
+	<wsdl:message name="UnableToCreatePullPoint">
+		<wsdl:part name="UnableToCreatePullPoint" element="wsnt:UnableToCreatePullPoint"/>
+	</wsdl:message>
+	<!-- ================ SubscriptionManager::Renew ==================
+   Renew( Duration | AbsoluteTime)
+   returns: (New Termination Time [CurrentTime])
+-->
+	<wsdl:message name="RenewRequest">
+		<wsdl:part name="RenewRequest" element="wsnt:Renew"/>
+	</wsdl:message>
+	<wsdl:message name="RenewResponse">
+		<wsdl:part name="RenewResponse" element="wsnt:RenewResponse"/>
+	</wsdl:message>
+	<wsdl:message name="UnacceptableTerminationTimeFault">
+		<wsdl:part name="UnacceptableTerminationTimeFault" element="wsnt:UnacceptableTerminationTimeFault"/>
+	</wsdl:message>
+	<!-- ============== SubscriptionManager::Unsubscribe ===============
+   Unsubscribe()
+   returns: empty
+-->
+	<wsdl:message name="UnsubscribeRequest">
+		<wsdl:part name="UnsubscribeRequest" element="wsnt:Unsubscribe"/>
+	</wsdl:message>
+	<wsdl:message name="UnsubscribeResponse">
+		<wsdl:part name="UnsubscribeResponse" element="wsnt:UnsubscribeResponse"/>
+	</wsdl:message>
+	<wsdl:message name="UnableToDestroySubscriptionFault">
+		<wsdl:part name="UnableToDestroySubscriptionFault" element="wsnt:UnableToDestroySubscriptionFault"/>
+	</wsdl:message>
+	<!-- ========== SubscriptionManager::PauseSubscription ============
+   PauseSubscription()
+   returns: empty
+-->
+	<wsdl:message name="PauseSubscriptionRequest">
+		<wsdl:part name="PauseSubscriptionRequest" element="wsnt:PauseSubscription"/>
+	</wsdl:message>
+	<wsdl:message name="PauseSubscriptionResponse">
+		<wsdl:part name="PauseSubscriptionResponse" element="wsnt:PauseSubscriptionResponse"/>
+	</wsdl:message>
+	<wsdl:message name="PauseFailedFault">
+		<wsdl:part name="PauseFailedFault" element="wsnt:PauseFailedFault"/>
+	</wsdl:message>
+	<!-- ========= SubscriptionManager::ResumeSubscription ============
+   ResumeSubscription()
+   returns: empty
+-->
+	<wsdl:message name="ResumeSubscriptionRequest">
+		<wsdl:part name="ResumeSubscriptionRequest" element="wsnt:ResumeSubscription"/>
+	</wsdl:message>
+	<wsdl:message name="ResumeSubscriptionResponse">
+		<wsdl:part name="ResumeSubscriptionResponse" element="wsnt:ResumeSubscriptionResponse"/>
+	</wsdl:message>
+	<wsdl:message name="ResumeFailedFault">
+		<wsdl:part name="ResumeFailedFault" element="wsnt:ResumeFailedFault"/>
+	</wsdl:message>
+	<!-- =================== PortType Definitions ===================== -->
+	<!-- ========= NotificationConsumer PortType Definition =========== -->
+	<wsdl:portType name="NotificationConsumer">
+		<wsdl:operation name="Notify">
+			<wsdl:input message="wsntw:Notify"/>
+		</wsdl:operation>
+	</wsdl:portType>
+	<!-- ========= NotificationProducer PortType Definition =========== -->
+	<wsdl:portType name="NotificationProducer">
+		<wsdl:operation name="Subscribe">
+			<wsdl:input message="wsntw:SubscribeRequest"/>
+			<wsdl:output message="wsntw:SubscribeResponse"/>
+			<wsdl:fault name="ResourceUnknownFault" message="wsrf-rw:ResourceUnknownFault"/>
+			<wsdl:fault name="InvalidFilterFault" message="wsntw:InvalidFilterFault"/>
+			<wsdl:fault name="TopicExpressionDialectUnknownFault" message="wsntw:TopicExpressionDialectUnknownFault"/>
+			<wsdl:fault name="InvalidTopicExpressionFault" message="wsntw:InvalidTopicExpressionFault"/>
+			<wsdl:fault name="TopicNotSupportedFault" message="wsntw:TopicNotSupportedFault"/>
+			<wsdl:fault name="InvalidProducerPropertiesExpressionFault" message="wsntw:InvalidProducerPropertiesExpressionFault"/>
+			<wsdl:fault name="InvalidMessageContentExpressionFault" message="wsntw:InvalidMessageContentExpressionFault"/>
+			<wsdl:fault name="InvalidUseRawValueFault" message="wsntw:InvalidUseRawValueFault"/>
+			<wsdl:fault name="UnacceptableInitialTerminationTimeFault" message="wsntw:UnacceptableInitialTerminationTimeFault"/>
+			<wsdl:fault name="SubscribeCreationFailedFault" message="wsntw:SubscribeCreationFailedFault"/>
+		</wsdl:operation>
+		<wsdl:operation name="GetCurrentMessage">
+			<wsdl:input message="wsntw:GetCurrentMessageRequest"/>
+			<wsdl:output message="wsntw:GetCurrentMessageResponse"/>
+			<wsdl:fault name="ResourceUnknownFault" message="wsrf-rw:ResourceUnknownFault"/>
+			<wsdl:fault name="TopicExpressionDialectUnknownFault" message="wsntw:TopicExpressionDialectUnknownFault"/>
+			<wsdl:fault name="InvalidTopicExpressionFault" message="wsntw:InvalidTopicExpressionFault"/>
+			<wsdl:fault name="TopicNotSupportedFault" message="wsntw:TopicNotSupportedFault"/>
+			<wsdl:fault name="NoCurrentMessageOnTopicFault" message="wsntw:NoCurrentMessageOnTopicFault"/>
+		</wsdl:operation>
+	</wsdl:portType>
+	<!-- ========== PullPoint PortType Definition ===================== -->
+	<wsdl:portType name="PullPoint">
+		<wsdl:operation name="GetMessages">
+			<wsdl:input name="GetMessagesRequest" message="wsntw:GetMessagesRequest"/>
+			<wsdl:output name="GetMessagesResponse" message="wsntw:GetMessagesResponse"/>
+			<wsdl:fault name="ResourceUnknownFault" message="wsrf-rw:ResourceUnknownFault"/>
+		</wsdl:operation>
+		<wsdl:operation name="Destroy">
+			<wsdl:input name="DestroyRequest" message="wsntw:DestroyRequest"/>
+			<wsdl:output name="DestroyResponse" message="wsntw:DestroyResponse"/>
+			<wsdl:fault name="UnableToDestroyPullPoint" message="wsntw:UnableToDestroyPullPoint"/>
+		</wsdl:operation>
+	</wsdl:portType>
+	<!-- ========== CreatePullPoint PortType Definition =============== -->
+	<wsdl:portType name="CreatePullPoint">
+		<wsdl:operation name="CreatePullPoint">
+			<wsdl:input name="CreatePullPointRequest" message="wsntw:CreatePullPointRequest"/>
+			<wsdl:output name="CreatePullPointResponse" message="wsntw:CreatePullPointResponse"/>
+			<wsdl:fault name="UnableToCreatePullPoint" message="wsntw:UnableToCreatePullPoint"/>
+		</wsdl:operation>
+	</wsdl:portType>
+	<!-- ========== SubscriptionManager PortType Definition =========== -->
+	<wsdl:portType name="SubscriptionManager">
+		<wsdl:operation name="Renew">
+			<wsdl:input name="RenewRequest" message="wsntw:RenewRequest"/>
+			<wsdl:output name="RenewResponse" message="wsntw:RenewResponse"/>
+			<wsdl:fault name="ResourceUnknownFault" message="wsrf-rw:ResourceUnknownFault"/>
+			<wsdl:fault name="UnacceptableTerminationTimeFault" message="wsntw:UnacceptableTerminationTimeFault"/>
+		</wsdl:operation>
+		<wsdl:operation name="Unsubscribe">
+			<wsdl:input name="UsubscribeRequest" message="wsntw:UnsubscribeRequest"/>
+			<wsdl:output name="UnsubscribeResponse" message="wsntw:UnsubscribeResponse"/>
+			<wsdl:fault name="ResourceUnknownFault" message="wsrf-rw:ResourceUnknownFault"/>
+			<wsdl:fault name="UnableToDestroySubscriptionFault" message="wsntw:UnableToDestroySubscriptionFault"/>
+		</wsdl:operation>
+	</wsdl:portType>
+	<!-- ====== PausableSubscriptionManager PortType Definition ======= -->
+	<wsdl:portType name="PausableSubscriptionManager">
+		<!-- ============== Extends: SubscriptionManager ============ -->
+		<wsdl:operation name="Renew">
+			<wsdl:input name="RenewRequest" message="wsntw:RenewRequest"/>
+			<wsdl:output name="RenewResponse" message="wsntw:RenewResponse"/>
+			<wsdl:fault name="ResourceUnknownFault" message="wsrf-rw:ResourceUnknownFault"/>
+			<wsdl:fault name="UnacceptableTerminationTimeFault" message="wsntw:UnacceptableTerminationTimeFault"/>
+		</wsdl:operation>
+		<wsdl:operation name="Unsubscribe">
+			<wsdl:input name="UsubscribeRequest" message="wsntw:UnsubscribeRequest"/>
+			<wsdl:output name="UnsubscribeResponse" message="wsntw:UnsubscribeResponse"/>
+			<wsdl:fault name="ResourceUnknownFault" message="wsrf-rw:ResourceUnknownFault"/>
+			<wsdl:fault name="UnableToDestroySubscriptionFault" message="wsntw:UnableToDestroySubscriptionFault"/>
+		</wsdl:operation>
+		<!-- === PausableSubscriptionManager specific operations === -->
+		<wsdl:operation name="PauseSubscription">
+			<wsdl:input message="wsntw:PauseSubscriptionRequest"/>
+			<wsdl:output message="wsntw:PauseSubscriptionResponse"/>
+			<wsdl:fault name="ResourceUnknownFault" message="wsrf-rw:ResourceUnknownFault"/>
+			<wsdl:fault name="PauseFailedFault" message="wsntw:PauseFailedFault"/>
+		</wsdl:operation>
+		<wsdl:operation name="ResumeSubscription">
+			<wsdl:input message="wsntw:ResumeSubscriptionRequest"/>
+			<wsdl:output message="wsntw:ResumeSubscriptionResponse"/>
+			<wsdl:fault name="ResourceUnknownFault" message="wsrf-rw:ResourceUnknownFault"/>
+			<wsdl:fault name="ResumeFailedFault" message="wsntw:ResumeFailedFault"/>
+		</wsdl:operation>
+	</wsdl:portType>
+</wsdl:definitions>

Added: incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/r-1.xsd
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/r-1.xsd?rev=357814&view=auto
==============================================================================
--- incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/r-1.xsd (added)
+++ incubator/servicemix/trunk/servicemix-wsn2005/src/main/wsdl/r-1.xsd Mon Dec 19 14:08:30 2005
@@ -0,0 +1,40 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!-- 
+
+OASIS takes no position regarding the validity or scope of any intellectual property or other rights that might be claimed to pertain to the implementation or use of the technology described in this document or the extent to which any license under such rights might or might not be available; neither does it represent that it has made any effort to identify any such rights. Information on OASIS's procedures with respect to rights in OASIS specifications can be found at the OASIS website. Copies of claims of rights made available for publication and any assurances of licenses to be made available, or the result of an attempt made to obtain a general license or permission for the use of such proprietary rights by implementors or users of this specification, can be obtained from the OASIS Executive Director.
+
+OASIS invites any interested party to bring to its attention any copyrights, patents or patent applications, or other proprietary rights which may cover technology that may be required to implement this specification. Please address the information to the OASIS Executive Director.
+
+Copyright (C) OASIS Open (2005). All Rights Reserved.
+
+This document and translations of it may be copied and furnished to others, and derivative works that comment on or otherwise explain it or assist in its implementation may be prepared, copied, published and distributed, in whole or in part, without restriction of any kind, provided that the above copyright notice and this paragraph are included on all such copies and derivative works. However, this document itself may not be modified in any way, such as by removing the copyright notice or references to OASIS, except as needed for the purpose of developing OASIS specifications, in which case the procedures for copyrights defined in the OASIS Intellectual Property Rights document must be followed, or as required to translate it into languages other than English. 
+
+The limited permissions granted above are perpetual and will not be revoked by OASIS or its successors or assigns. 
+
+This document and the information contained herein is provided on an "AS IS" basis and OASIS DISCLAIMS ALL WARRANTIES, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO ANY WARRANTY THAT THE USE OF THE INFORMATION HEREIN WILL NOT INFRINGE ANY RIGHTS OR ANY IMPLIED WARRANTIES OF MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE.
+
+-->
+<xsd:schema 
+  xmlns:xsd="http://www.w3.org/2001/XMLSchema"
+  xmlns:wsrf-r="http://docs.oasis-open.org/wsrf/r-1"
+  xmlns:wsrf-bf="http://docs.oasis-open.org/wsrf/bf-1"
+  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  elementFormDefault="qualified" attributeFormDefault="unqualified" 
+  targetNamespace="http://docs.oasis-open.org/wsrf/r-1" 
+>
+ 
+  <xsd:import namespace="http://docs.oasis-open.org/wsrf/bf-1"
+              schemaLocation="bf-1.xsd"
+  />
+
+<!-- ====================== WS-Resource fault types ============= -->
+ 
+      <xsd:complexType name="ResourceUnknownFaultType">
+         <xsd:complexContent>
+            <xsd:extension base="wsrf-bf:BaseFaultType"/>
+         </xsd:complexContent>
+      </xsd:complexType>
+      <xsd:element name="ResourceUnknownFault" 
+                   type="wsrf-r:ResourceUnknownFaultType"/>
+</xsd:schema>
+



Mime
View raw message