[jbossws-commits] JBossWS SVN: r4534 - in stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm: common and 5 other directories.

Monday, 10 September 2007


Author: richard.opalka(a)jboss.com
Date: 2007-09-10 04:27:49 -0400 (Mon, 10 Sep 2007)
New Revision: 4534

Added:
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/ReliableMessagingException.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SerializationHelper.java
Modified:
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/ConstantsImpl.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/AbstractSerializable.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/AckRequestedSerializer.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CloseSequenceResponseSerializer.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CloseSequenceSerializer.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CreateSequenceResponseSerializer.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CreateSequenceSerializer.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SequenceAcknowledgementSerializer.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SequenceFaultSerializer.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SequenceSerializer.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SerializationRepository.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/TerminateSequenceResponseSerializer.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/TerminateSequenceSerializer.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200502/ProviderImpl.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/ProviderImpl.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/Constants.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/IncompleteSequenceBehavior.java
  
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/Serializable.java
Log:
adding RM exception + implemented CreateSequence de/serializer

Added:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/ReliableMessagingException.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/ReliableMessagingException.java	
                       (rev 0)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/ReliableMessagingException.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -0,0 +1,53 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2005, JBoss Inc., and individual contributors as indicated
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.ws.extensions.wsrm;
+
+import javax.xml.ws.WebServiceException;
+
+/**
+ * RM exception heavily used by RM framework
+ * @author richard.opalka(a)jboss.com
+ */
+public class ReliableMessagingException extends WebServiceException
+{
+
+   public ReliableMessagingException()
+   {
+      super();
+   }
+
+   public ReliableMessagingException(String message, Throwable cause)
+   {
+      super(message, cause);
+   }
+
+   public ReliableMessagingException(String message)
+   {
+      super(message);
+   }
+
+   public ReliableMessagingException(Throwable cause)
+   {
+      super(cause);
+   }
+
+}


Property changes on:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/ReliableMessagingException.java
___________________________________________________________________
Name: svn:keywords
   + Id Revision
Name: svn:eol-style
   + LF

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/ConstantsImpl.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/ConstantsImpl.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/ConstantsImpl.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -32,9 +32,9 @@
  */
 public final class ConstantsImpl implements Constants
 {
-   // default namespace prefix
-   private static final String WSRM_PREFIX = "wsrm";
-   // heavily used constants
+   
+   private final String prefix;
+   private final String namespaceURI;
    private final QName acceptQName;
    private final QName ackRequestedQName;
    private final QName acknowledgementRangeQName;
@@ -65,48 +65,63 @@
    private final QName terminateSequenceResponseQName;
    private final QName upperQName;
    
-   public ConstantsImpl(String namespace)
+   public ConstantsImpl(String prefix, String namespaceURI)
    {
-      if ((namespace == null) || (namespace.trim().equals("")))
-         throw new IllegalArgumentException();
-         
-      acceptQName = new QName(WSRM_PREFIX, namespace, "Accept");
-      ackRequestedQName = new QName(WSRM_PREFIX, namespace, "AckRequested");
-      acknowledgementRangeQName = new QName(WSRM_PREFIX, namespace,
"AcknowledgementRange");
-      acksToQName = new QName(WSRM_PREFIX, namespace, "AcksTo");
-      closeSequenceQName = new QName(WSRM_PREFIX, namespace, "CloseSequence");
-      closeSequenceResponseQName = new QName(WSRM_PREFIX, namespace,
"CloseSequenceResponse");
-      createSequenceQName = new QName(WSRM_PREFIX, namespace,
"CreateSequence");
-      createSequenceResponseQName = new QName(WSRM_PREFIX, namespace,
"CreateSequenceResponse");
-      detailQName = new QName(WSRM_PREFIX, namespace, "Detail");
-      endpointQName = new QName(WSRM_PREFIX, namespace, "Endpoint");
-      expiresQName = new QName(WSRM_PREFIX, namespace, "Expires");
-      faultCodeQName = new QName(WSRM_PREFIX, namespace, "FaultCode");
-      finalQName = new QName(WSRM_PREFIX, namespace, "Final");
-      identifierQName = new QName(WSRM_PREFIX, namespace, "Identifier");
-      incompleteSequenceBehaviorQName = new QName(WSRM_PREFIX, namespace,
"IncompleteSequenceBehavior");
-      lastMessageNumberQName = new QName(WSRM_PREFIX, namespace,
"LastMessageNumber");
-      lastMessageQName = new QName(WSRM_PREFIX, namespace, "LastMessage");
-      lastMsgNumberQName = new QName(WSRM_PREFIX, namespace, "LastMsgNumber");
-      lowerQName = new QName(WSRM_PREFIX, namespace, "Lower");
-      messageNumberQName = new QName(WSRM_PREFIX, namespace, "MessageNumber");
-      nackQName = new QName(WSRM_PREFIX, namespace, "Nack");
-      noneQName = new QName(WSRM_PREFIX, namespace, "None");
-      offerQName = new QName(WSRM_PREFIX, namespace, "Offer");
-      sequenceAcknowledgementQName = new QName(WSRM_PREFIX, namespace,
"SequenceAcknowledgement");
-      sequenceFaultQName = new QName(WSRM_PREFIX, namespace, "SequenceFault");
-      equenceQName = new QName(WSRM_PREFIX, namespace, "Sequence");
-      terminateSequenceQName = new QName(WSRM_PREFIX, namespace,
"TerminateSequence");
-      terminateSequenceResponseQName = new QName(WSRM_PREFIX, namespace,
"TerminateSequenceResponse");
-      upperQName = new QName(WSRM_PREFIX, namespace, "Upper");
+      this.prefix = prefix;
+      this.namespaceURI = namespaceURI;
+      this.acceptQName = new QName(namespaceURI, "Accept", prefix);
+      this.ackRequestedQName = new QName(namespaceURI, "AckRequested",
prefix);
+      this.acknowledgementRangeQName = new QName(namespaceURI,
"AcknowledgementRange", prefix);
+      this.acksToQName = new QName(namespaceURI, "AcksTo", prefix);
+      this.closeSequenceQName = new QName(namespaceURI, "CloseSequence",
prefix);
+      this.closeSequenceResponseQName = new QName(namespaceURI,
"CloseSequenceResponse", prefix);
+      this.createSequenceQName = new QName(namespaceURI, "CreateSequence",
prefix);
+      this.createSequenceResponseQName = new QName(namespaceURI,
"CreateSequenceResponse", prefix);
+      this.detailQName = new QName(namespaceURI, "Detail", prefix);
+      this.endpointQName = new QName(namespaceURI, "Endpoint", prefix);
+      this.expiresQName = new QName(namespaceURI, "Expires", prefix);
+      this.faultCodeQName = new QName(namespaceURI, "FaultCode", prefix);
+      this.finalQName = new QName(namespaceURI, "Final", prefix);
+      this.identifierQName = new QName(namespaceURI, "Identifier", prefix);
+      this.incompleteSequenceBehaviorQName = new QName(namespaceURI,
"IncompleteSequenceBehavior", prefix);
+      this.lastMessageNumberQName = new QName(namespaceURI,
"LastMessageNumber", prefix);
+      this.lastMessageQName = new QName(namespaceURI, "LastMessage", prefix);
+      this.lastMsgNumberQName = new QName(namespaceURI, "LastMsgNumber",
prefix);
+      this.lowerQName = new QName(namespaceURI, "Lower", prefix);
+      this.messageNumberQName = new QName(namespaceURI, "MessageNumber",
prefix);
+      this.nackQName = new QName(namespaceURI, "Nack", prefix);
+      this.noneQName = new QName(namespaceURI, "None", prefix);
+      this.offerQName = new QName(namespaceURI, "Offer", prefix);
+      this.sequenceAcknowledgementQName = new QName(namespaceURI,
"SequenceAcknowledgement", prefix);
+      this.sequenceFaultQName = new QName(namespaceURI, "SequenceFault",
prefix);
+      this.equenceQName = new QName(namespaceURI, "Sequence", prefix);
+      this.terminateSequenceQName = new QName(namespaceURI,
"TerminateSequence", prefix);
+      this.terminateSequenceResponseQName = new QName(namespaceURI,
"TerminateSequenceResponse", prefix);
+      this.upperQName = new QName(namespaceURI, "Upper", prefix);
    }
    
    /**
+    * @see org.jboss.ws.extensions.wsrm.spi.Constants#getPrefix()
+    */
+   public final String getPrefix()
+   {
+      return this.prefix;
+   }
+   
+   /**
+    * @see org.jboss.ws.extensions.wsrm.spi.Constants#getNamespaceURI()
+    */
+   public final String getNamespaceURI()
+   {
+      return this.namespaceURI;
+   }
+   
+   /**
     * @see org.jboss.ws.extensions.wsrm.spi.Constants#getAcceptQName()
     */
    public final QName getAcceptQName()
    {
-      return acceptQName;
+      return this.acceptQName;
    }
 
    /**
@@ -114,7 +129,7 @@
     */
    public final QName getAckRequestedQName()
    {
-      return ackRequestedQName;
+      return this.ackRequestedQName;
    }
 
    /**
@@ -122,7 +137,7 @@
     */
    public final QName getAcknowledgementRangeQName()
    {
-      return acknowledgementRangeQName;
+      return this.acknowledgementRangeQName;
    }
 
    /**
@@ -130,7 +145,7 @@
     */
    public final QName getAcksToQName()
    {
-      return acksToQName;
+      return this.acksToQName;
    }
 
    /**
@@ -138,7 +153,7 @@
     */
    public final QName getCloseSequenceQName()
    {
-      return closeSequenceQName;
+      return this.closeSequenceQName;
    }
 
    /**
@@ -146,7 +161,7 @@
     */
    public final QName getCloseSequenceResponseQName()
    {
-      return closeSequenceResponseQName;
+      return this.closeSequenceResponseQName;
    }
 
    /**
@@ -154,7 +169,7 @@
     */
    public final QName getCreateSequenceQName()
    {
-      return createSequenceQName;
+      return this.createSequenceQName;
    }
 
    /**
@@ -162,7 +177,7 @@
     */
    public final QName getCreateSequenceResponseQName()
    {
-      return createSequenceResponseQName;
+      return this.createSequenceResponseQName;
    }
 
    /**
@@ -170,7 +185,7 @@
     */
    public final QName getDetailQName()
    {
-      return detailQName;
+      return this.detailQName;
    }
 
    /**
@@ -178,7 +193,7 @@
     */
    public final QName getEndpointQName()
    {
-      return endpointQName;
+      return this.endpointQName;
    }
 
    /**
@@ -186,7 +201,7 @@
     */
    public final QName getExpiresQName()
    {
-      return expiresQName;
+      return this.expiresQName;
    }
 
    /**
@@ -194,7 +209,7 @@
     */
    public final QName getFaultCodeQName()
    {
-      return faultCodeQName;
+      return this.faultCodeQName;
    }
 
    /**
@@ -202,7 +217,7 @@
     */
    public final QName getFinalQName()
    {
-      return finalQName;
+      return this.finalQName;
    }
 
    /**
@@ -210,7 +225,7 @@
     */
    public final QName getIdentifierQName()
    {
-      return identifierQName;
+      return this.identifierQName;
    }
 
    /**
@@ -218,7 +233,7 @@
     */
    public final QName getIncompleteSequenceBehaviorQName()
    {
-      return incompleteSequenceBehaviorQName;
+      return this.incompleteSequenceBehaviorQName;
    }
 
    /**
@@ -226,7 +241,7 @@
     */
    public final QName getLastMessageNumberQName()
    {
-      return lastMessageNumberQName;
+      return this.lastMessageNumberQName;
    }
 
    /**
@@ -234,7 +249,7 @@
     */
    public final QName getLastMessageQName()
    {
-      return lastMessageQName;
+      return this.lastMessageQName;
    }
 
    /**
@@ -242,7 +257,7 @@
     */
    public final QName getLastMsgNumberQName()
    {
-      return lastMsgNumberQName;
+      return this.lastMsgNumberQName;
    }
 
    /**
@@ -250,7 +265,7 @@
     */
    public final QName getLowerQName()
    {
-      return lowerQName;
+      return this.lowerQName;
    }
 
    /**
@@ -258,7 +273,7 @@
     */
    public final QName getMessageNumberQName()
    {
-      return messageNumberQName;
+      return this.messageNumberQName;
    }
 
    /**
@@ -266,7 +281,7 @@
     */
    public final QName getNackQName()
    {
-      return nackQName;
+      return this.nackQName;
    }
 
    /**
@@ -274,7 +289,7 @@
     */
    public final QName getNoneQName()
    {
-      return noneQName;
+      return this.noneQName;
    }
 
    /**
@@ -282,7 +297,7 @@
     */
    public final QName getOfferQName()
    {
-      return offerQName;
+      return this.offerQName;
    }
 
    /**
@@ -290,7 +305,7 @@
     */
    public final QName getSequenceAcknowledgementQName()
    {
-      return sequenceAcknowledgementQName;
+      return this.sequenceAcknowledgementQName;
    }
 
    /**
@@ -298,7 +313,7 @@
     */
    public final QName getSequenceFaultQName()
    {
-      return sequenceFaultQName;
+      return this.sequenceFaultQName;
    }
 
    /**
@@ -306,7 +321,7 @@
     */
    public final QName getSequenceQName()
    {
-      return equenceQName;
+      return this.equenceQName;
    }
 
    /**
@@ -314,7 +329,7 @@
     */
    public final QName getTerminateSequenceQName()
    {
-      return terminateSequenceQName;
+      return this.terminateSequenceQName;
    }
 
    /**
@@ -322,7 +337,7 @@
     */
    public final QName getTerminateSequenceResponseQName()
    {
-      return terminateSequenceResponseQName;
+      return this.terminateSequenceResponseQName;
    }
 
    /**
@@ -330,7 +345,7 @@
     */
    public final QName getUpperQName()
    {
-      return upperQName;
+      return this.upperQName;
    }
 
 }

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/AbstractSerializable.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/AbstractSerializable.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/AbstractSerializable.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -22,6 +22,8 @@
 package org.jboss.ws.extensions.wsrm.common.serialization;
 
 import javax.xml.soap.SOAPMessage;
+
+import org.jboss.ws.extensions.wsrm.ReliableMessagingException;
 import org.jboss.ws.extensions.wsrm.spi.Provider;
 import org.jboss.ws.extensions.wsrm.spi.protocol.Serializable;
 
@@ -41,7 +43,7 @@
    /*
     * @see
org.jboss.ws.extensions.wsrm.spi.protocol.Serializable#deserializeFrom(javax.xml.soap.SOAPMessage)
     */
-   public final void deserializeFrom(SOAPMessage soapMessage)
+   public final void deserializeFrom(SOAPMessage soapMessage) throws
ReliableMessagingException
    {
       SerializationRepository.deserialize(this, soapMessage);
       validate(); // finally ensure that object is in correct state
@@ -50,7 +52,7 @@
    /*
     * @see
org.jboss.ws.extensions.wsrm.spi.protocol.Serializable#serializeTo(javax.xml.soap.SOAPMessage)
     */
-   public final void serializeTo(SOAPMessage soapMessage)
+   public final void serializeTo(SOAPMessage soapMessage) throws
ReliableMessagingException
    {
       validate(); // ensure object is in correct state first
       SerializationRepository.serialize(this, soapMessage);

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/AckRequestedSerializer.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/AckRequestedSerializer.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/AckRequestedSerializer.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -24,6 +24,7 @@
 import javax.xml.soap.SOAPMessage;
 
 import org.jboss.util.NotImplementedException;
+import org.jboss.ws.extensions.wsrm.ReliableMessagingException;
 import org.jboss.ws.extensions.wsrm.spi.Provider;
 import org.jboss.ws.extensions.wsrm.spi.protocol.AckRequested;
 
@@ -46,6 +47,7 @@
     * @param soapMessage soap message from which object will be deserialized
     */
    public static void deserialize(AckRequested object, Provider provider, SOAPMessage
soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }
@@ -57,6 +59,7 @@
     * @param soapMessage soap message to which object will be serialized
     */
    public static void serialize(AckRequested object, Provider provider, SOAPMessage
soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CloseSequenceResponseSerializer.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CloseSequenceResponseSerializer.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CloseSequenceResponseSerializer.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -24,6 +24,7 @@
 import javax.xml.soap.SOAPMessage;
 
 import org.jboss.util.NotImplementedException;
+import org.jboss.ws.extensions.wsrm.ReliableMessagingException;
 import org.jboss.ws.extensions.wsrm.spi.Provider;
 import org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequenceResponse;
 
@@ -46,6 +47,7 @@
     * @param soapMessage soap message from which object will be deserialized
     */
    public static void deserialize(CloseSequenceResponse object, Provider provider,
SOAPMessage soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }
@@ -57,6 +59,7 @@
     * @param soapMessage soap message to which object will be serialized
     */
    public static void serialize(CloseSequenceResponse object, Provider provider,
SOAPMessage soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CloseSequenceSerializer.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CloseSequenceSerializer.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CloseSequenceSerializer.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -24,6 +24,7 @@
 import javax.xml.soap.SOAPMessage;
 
 import org.jboss.util.NotImplementedException;
+import org.jboss.ws.extensions.wsrm.ReliableMessagingException;
 import org.jboss.ws.extensions.wsrm.spi.Provider;
 import org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequence;
 
@@ -46,6 +47,7 @@
     * @param soapMessage soap message from which object will be deserialized
     */
    public static void deserialize(CloseSequence object, Provider provider, SOAPMessage
soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }
@@ -57,6 +59,7 @@
     * @param soapMessage soap message to which object will be serialized
     */
    public static void serialize(CloseSequence object, Provider provider, SOAPMessage
soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CreateSequenceResponseSerializer.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CreateSequenceResponseSerializer.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CreateSequenceResponseSerializer.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -24,6 +24,7 @@
 import javax.xml.soap.SOAPMessage;
 
 import org.jboss.util.NotImplementedException;
+import org.jboss.ws.extensions.wsrm.ReliableMessagingException;
 import org.jboss.ws.extensions.wsrm.spi.Provider;
 import org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequenceResponse;
 
@@ -46,6 +47,7 @@
     * @param soapMessage soap message from which object will be deserialized
     */
    public static void deserialize(CreateSequenceResponse object, Provider provider,
SOAPMessage soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }
@@ -57,6 +59,7 @@
     * @param soapMessage soap message to which object will be serialized
     */
    public static void serialize(CreateSequenceResponse object, Provider provider,
SOAPMessage soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CreateSequenceSerializer.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CreateSequenceSerializer.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/CreateSequenceSerializer.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -21,11 +21,23 @@
  */
 package org.jboss.ws.extensions.wsrm.common.serialization;
 
+import static org.jboss.ws.extensions.wsrm.common.serialization.SerializationHelper.*;
+
+import javax.xml.namespace.QName;
+import javax.xml.soap.SOAPBody;
+import javax.xml.soap.SOAPElement;
+import javax.xml.soap.SOAPEnvelope;
+import javax.xml.soap.SOAPException;
 import javax.xml.soap.SOAPMessage;
+import javax.xml.ws.addressing.AddressingBuilder;
+import javax.xml.ws.addressing.AddressingConstants;
 
-import org.jboss.util.NotImplementedException;
+import org.jboss.ws.extensions.wsrm.ReliableMessagingException;
+import org.jboss.ws.extensions.wsrm.spi.Constants;
 import org.jboss.ws.extensions.wsrm.spi.Provider;
 import org.jboss.ws.extensions.wsrm.spi.protocol.CreateSequence;
+import org.jboss.ws.extensions.wsrm.spi.protocol.IncompleteSequenceBehavior;
+import org.w3c.dom.Element;
 
 /**
  * <b>CreateSequence</b> object de/serializer
@@ -34,6 +46,9 @@
 final class CreateSequenceSerializer
 {
 
+   private static final AddressingConstants ADDRESSING_CONSTANTS = 
+      AddressingBuilder.getAddressingBuilder().newAddressingConstants();
+   
    private CreateSequenceSerializer()
    {
       // no instances
@@ -46,10 +61,84 @@
     * @param soapMessage soap message from which object will be deserialized
     */
    public static void deserialize(CreateSequence object, Provider provider, SOAPMessage
soapMessage)
+   throws ReliableMessagingException
    {
-      throw new NotImplementedException();
+      try
+      {
+         SOAPBody soapBody = soapMessage.getSOAPPart().getEnvelope().getBody();
+         Constants wsrmConstants = provider.getConstants();
+         
+         // read wsrm:CreateSequence
+         QName createSequenceQName = wsrmConstants.getCreateSequenceQName();
+         Element createSequenceElement = getRequiredElement(soapBody,
createSequenceQName, "soap body");
+
+         // read wsrm:AcksTo
+         QName acksToQName = wsrmConstants.getAcksToQName();
+         Element acksToElement = getRequiredElement(createSequenceElement, acksToQName,
createSequenceQName);
+         QName addressQName = ADDRESSING_CONSTANTS.getAddressQName();
+         Element acksToAddressElement = getRequiredElement(acksToElement, addressQName,
acksToQName);
+         String acksToAddress = getRequiredTextContent(acksToAddressElement,
addressQName);
+         object.setAcksTo(acksToAddress);
+
+         // read wsrm:Expires
+         QName expiresQName = wsrmConstants.getExpiresQName();
+         Element expiresElement = getOptionalElement(createSequenceElement, expiresQName,
createSequenceQName);
+         if (expiresElement != null)
+         {
+            String duration = getRequiredTextContent(expiresElement, expiresQName);
+            object.setExpires(duration);
+         }
+
+         // read wsrm:Offer
+         QName offerQName = wsrmConstants.getOfferQName();
+         Element offerElement = getOptionalElement(createSequenceElement, offerQName,
createSequenceQName);
+         if (offerElement != null)
+         {
+            CreateSequence.Offer offer = object.newOffer();
+
+            // read wsrm:identifier
+            QName identifierQName = wsrmConstants.getIdentifierQName();
+            Element identifierElement = getRequiredElement(offerElement, identifierQName,
offerQName);
+            String identifier = getRequiredTextContent(identifierElement,
identifierQName);
+            offer.setIdentifier(identifier);
+            
+            // read wsrm:Endpoint
+            QName endpointQName = wsrmConstants.getEndpointQName();
+            Element endpointElement = getOptionalElement(offerElement, endpointQName,
offerQName);
+            if (endpointElement != null)
+            {
+               Element endpointAddressElement = getRequiredElement(endpointElement,
addressQName, endpointQName);
+               String endpointAddress = getRequiredTextContent(endpointAddressElement,
addressQName);
+               offer.setEndpoint(endpointAddress);
+            }
+            
+            // read wsrm:Expires
+            Element offerExpiresElement = getOptionalElement(offerElement, expiresQName,
offerQName);
+            if (offerExpiresElement != null)
+            {
+               String duration = getRequiredTextContent(offerExpiresElement,
expiresQName);
+               offer.setExpires(duration);
+            }
+            
+            // read wsrm:IncompleteSequenceBehavior
+            QName behaviorQName = wsrmConstants.getIncompleteSequenceBehaviorQName();
+            Element behaviorElement = getOptionalElement(offerElement, behaviorQName,
offerQName);
+            if (behaviorElement != null)
+            {
+               String behaviorString = getRequiredTextContent(behaviorElement,
behaviorQName);
+              
offer.setIncompleteSequenceBehavior(IncompleteSequenceBehavior.getValue(behaviorString));
+            }
+            
+            // set created offer
+            object.setOffer(offer);
+         }
+      }
+      catch (SOAPException se)
+      {
+         throw new ReliableMessagingException("Unable to deserialize RM
message", se);
+      }
    }
-
+   
    /**
     * Serialize <b>CreateSequence</b> using <b>provider</b> to
the <b>soapMessage</b>
     * @param object to be serialized
@@ -57,8 +146,76 @@
     * @param soapMessage soap message to which object will be serialized
     */
    public static void serialize(CreateSequence object, Provider provider, SOAPMessage
soapMessage)
+   throws ReliableMessagingException
    {
-      throw new NotImplementedException();
+      try
+      {
+         SOAPEnvelope soapEnvelope = soapMessage.getSOAPPart().getEnvelope();
+         Constants wsrmConstants = provider.getConstants();
+         
+         // Add xmlns:wsrm declaration
+         soapEnvelope.addNamespaceDeclaration(wsrmConstants.getPrefix(),
wsrmConstants.getNamespaceURI());
+
+         // write wsrm:CreateSequence
+         QName createSequenceQName = wsrmConstants.getCreateSequenceQName(); 
+         SOAPElement createSequenceElement =
soapEnvelope.getBody().addChildElement(createSequenceQName);
+         
+         // write wsrm:AcksTo
+         QName acksToQName = wsrmConstants.getAcksToQName();
+         QName addressQName = ADDRESSING_CONSTANTS.getAddressQName();
+         createSequenceElement.addChildElement(acksToQName)
+            .addChildElement(addressQName)
+               .setValue(object.getAcksTo());
+         
+         if (object.getExpires() != null)
+         {
+            // write wsrm:Expires
+            QName expiresQName = wsrmConstants.getExpiresQName();
+           
createSequenceElement.addChildElement(expiresQName).setValue(object.getExpires());
+         }
+         
+         if (object.getOffer() != null)
+         {
+            CreateSequence.Offer offer = object.getOffer();
+            
+            // write wsrm:Offer
+            QName offerQName = wsrmConstants.getOfferQName();
+            SOAPElement offerElement =
createSequenceElement.addChildElement(offerQName);
+
+            // write wsrm:Identifier
+            QName identifierQName = wsrmConstants.getIdentifierQName();
+           
offerElement.addChildElement(identifierQName).setValue(offer.getIdentifier());
+            
+            if (offer.getEndpoint() != null)
+            {
+               // write wsrm:Endpoint
+               QName endpointQName = wsrmConstants.getEndpointQName();
+               offerElement.addChildElement(endpointQName)
+                  .addChildElement(addressQName)
+                     .setValue(offer.getEndpoint());
+            }
+            
+            if (offer.getExpires() != null)
+            {
+               // write wsrm:Expires
+               QName expiresQName = wsrmConstants.getExpiresQName();
+               offerElement.addChildElement(expiresQName).setValue(offer.getExpires());
+            }
+            
+            if (offer.getIncompleteSequenceBehavior() != null)
+            {
+               // write wsrm:IncompleteSequenceBehavior
+               IncompleteSequenceBehavior behavior =
offer.getIncompleteSequenceBehavior();
+               QName behaviorQName = wsrmConstants.getIncompleteSequenceBehaviorQName();
+               SOAPElement behaviorElement =
offerElement.addChildElement(behaviorQName);
+               behaviorElement.setValue(behavior.toString());
+            }
+         }
+      }
+      catch (SOAPException se)
+      {
+         throw new ReliableMessagingException("Unable to serialize RM message",
se);
+      }
    }
 
 }

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SequenceAcknowledgementSerializer.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SequenceAcknowledgementSerializer.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SequenceAcknowledgementSerializer.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -24,6 +24,7 @@
 import javax.xml.soap.SOAPMessage;
 
 import org.jboss.util.NotImplementedException;
+import org.jboss.ws.extensions.wsrm.ReliableMessagingException;
 import org.jboss.ws.extensions.wsrm.spi.Provider;
 import org.jboss.ws.extensions.wsrm.spi.protocol.SequenceAcknowledgement;
 
@@ -46,6 +47,7 @@
     * @param soapMessage soap message from which object will be deserialized
     */
    public static void deserialize(SequenceAcknowledgement object, Provider provider,
SOAPMessage soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }
@@ -57,6 +59,7 @@
     * @param soapMessage soap message to which object will be serialized
     */
    public static void serialize(SequenceAcknowledgement object, Provider provider,
SOAPMessage soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SequenceFaultSerializer.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SequenceFaultSerializer.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SequenceFaultSerializer.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -24,6 +24,7 @@
 import javax.xml.soap.SOAPMessage;
 
 import org.jboss.util.NotImplementedException;
+import org.jboss.ws.extensions.wsrm.ReliableMessagingException;
 import org.jboss.ws.extensions.wsrm.spi.Provider;
 import org.jboss.ws.extensions.wsrm.spi.protocol.SequenceFault;
 
@@ -46,6 +47,7 @@
     * @param soapMessage soap message from which object will be deserialized
     */
    public static void deserialize(SequenceFault object, Provider provider, SOAPMessage
soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }
@@ -57,6 +59,7 @@
     * @param soapMessage soap message to which object will be serialized
     */
    public static void serialize(SequenceFault object, Provider provider, SOAPMessage
soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SequenceSerializer.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SequenceSerializer.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SequenceSerializer.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -24,6 +24,7 @@
 import javax.xml.soap.SOAPMessage;
 
 import org.jboss.util.NotImplementedException;
+import org.jboss.ws.extensions.wsrm.ReliableMessagingException;
 import org.jboss.ws.extensions.wsrm.spi.Provider;
 import org.jboss.ws.extensions.wsrm.spi.protocol.Sequence;
 
@@ -46,6 +47,7 @@
     * @param soapMessage soap message from which object will be deserialized
     */
    public static void deserialize(Sequence object, Provider provider, SOAPMessage
soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }
@@ -57,6 +59,7 @@
     * @param soapMessage soap message to which object will be serialized
     */
    public static void serialize(Sequence object, Provider provider, SOAPMessage
soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }

Added:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SerializationHelper.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SerializationHelper.java	
                       (rev 0)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SerializationHelper.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -0,0 +1,81 @@
+package org.jboss.ws.extensions.wsrm.common.serialization;
+
+import java.util.List;
+import javax.xml.namespace.QName;
+import org.jboss.ws.extensions.wsrm.ReliableMessagingException;
+import org.jboss.wsf.common.DOMUtils;
+import org.w3c.dom.Element;
+
+final class SerializationHelper
+{
+   
+   private SerializationHelper()
+   {
+      // no instances
+   }
+   
+   public static String getRequiredTextContent(Element element, QName nodeName)
+   {
+      if (!DOMUtils.hasTextChildNodesOnly(element))
+         throw new ReliableMessagingException(
+            "Only text content is allowed for element " +
nodeName.getLocalPart());
+
+      return DOMUtils.getTextContent(element).trim();
+   }
+   
+   private static Element getRequiredElementFromList(List<Element> list, QName
requiredQName, QName contextQName)
+   {
+      return getRequiredElementFromList(list, requiredQName.getLocalPart(),
contextQName.getLocalPart());
+   }
+   
+   private static Element getRequiredElementFromList(List<Element> list, QName
requiredQName, String context)
+   {
+      return getRequiredElementFromList(list, requiredQName.getLocalPart(), context);
+   }
+   
+   public static Element getRequiredElement(Element element, QName requiredQName, QName
contextQName)
+   {
+      List<Element> list = DOMUtils.getChildElementsAsList(element,
requiredQName);
+      return getRequiredElementFromList(list, requiredQName, contextQName);
+   }
+   
+   public static Element getRequiredElement(Element element, QName requiredQName, String
context)
+   {
+      List<Element> list = DOMUtils.getChildElementsAsList(element,
requiredQName);
+      return getRequiredElementFromList(list, requiredQName, context);
+   }
+   
+   public static Element getOptionalElement(Element element, QName optionalQName, QName
contextQName)
+   {
+      List<Element> list = DOMUtils.getChildElementsAsList(element,
optionalQName);
+      return getOptionalElementFromList(list, optionalQName, contextQName);
+   }
+   
+   private static Element getOptionalElementFromList(List<Element> list, QName
requiredQName, QName contextQName)
+   {
+      return getOptionalElementFromList(list, requiredQName.getLocalPart(),
contextQName.getLocalPart());
+   }
+
+   private static Element getOptionalElementFromList(List<Element> list, String
required, String context)
+   {
+      if (list.size() > 1)
+         throw new ReliableMessagingException(
+            "At most one " + required + " element can be present in "
+ context + " element");
+      
+      return (list.size() == 1) ? list.get(0) : null;
+   }
+   
+   private static Element getRequiredElementFromList(List<Element> list, String
required, String context)
+   {
+      if (list.size() < 1)
+         throw new ReliableMessagingException(
+            "Required " + required + " element not found in " +
context + " element");
+      
+      if (list.size() > 1)
+         throw new ReliableMessagingException(
+            "Only one " + required + " element can be present in " +
context + " element");
+      
+      return list.get(0);
+   }
+   
+}


Property changes on:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SerializationHelper.java
___________________________________________________________________
Name: svn:keywords
   + Id Revision
Name: svn:eol-style
   + LF

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SerializationRepository.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SerializationRepository.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/SerializationRepository.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -21,6 +21,7 @@
  */
 package org.jboss.ws.extensions.wsrm.common.serialization;
 
+import org.jboss.ws.extensions.wsrm.ReliableMessagingException;
 import org.jboss.ws.extensions.wsrm.spi.Provider;
 import org.jboss.ws.extensions.wsrm.spi.protocol.AckRequested;
 import org.jboss.ws.extensions.wsrm.spi.protocol.CloseSequence;
@@ -46,7 +47,7 @@
       // forbidden inheritance
    }
    
-   public static void serialize(AbstractSerializable object, SOAPMessage soapMessage)
+   public static void serialize(AbstractSerializable object, SOAPMessage soapMessage)
throws ReliableMessagingException
    {
       Provider provider = object.getProvider();
       
@@ -80,11 +81,9 @@
       if (object instanceof TerminateSequenceResponse)
          TerminateSequenceResponseSerializer
             .serialize((TerminateSequenceResponse)object, provider, soapMessage);
-      
-      throw new IllegalArgumentException();
    }
 
-   public static void deserialize(AbstractSerializable object, SOAPMessage soapMessage)
+   public static void deserialize(AbstractSerializable object, SOAPMessage soapMessage)
throws ReliableMessagingException
    {
       Provider provider = object.getProvider();
       
@@ -118,8 +117,6 @@
       if (object instanceof TerminateSequenceResponse)
          TerminateSequenceResponseSerializer
             .deserialize((TerminateSequenceResponse)object, provider, soapMessage);
-      
-      throw new IllegalArgumentException();
    }
    
 }

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/TerminateSequenceResponseSerializer.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/TerminateSequenceResponseSerializer.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/TerminateSequenceResponseSerializer.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -24,6 +24,7 @@
 import javax.xml.soap.SOAPMessage;
 
 import org.jboss.util.NotImplementedException;
+import org.jboss.ws.extensions.wsrm.ReliableMessagingException;
 import org.jboss.ws.extensions.wsrm.spi.Provider;
 import org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequenceResponse;
 
@@ -46,6 +47,7 @@
     * @param soapMessage soap message from which object will be deserialized
     */
    public static void deserialize(TerminateSequenceResponse object, Provider provider,
SOAPMessage soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }
@@ -57,6 +59,7 @@
     * @param soapMessage soap message to which object will be serialized
     */
    public static void serialize(TerminateSequenceResponse object, Provider provider,
SOAPMessage soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/TerminateSequenceSerializer.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/TerminateSequenceSerializer.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/common/serialization/TerminateSequenceSerializer.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -24,6 +24,7 @@
 import javax.xml.soap.SOAPMessage;
 
 import org.jboss.util.NotImplementedException;
+import org.jboss.ws.extensions.wsrm.ReliableMessagingException;
 import org.jboss.ws.extensions.wsrm.spi.Provider;
 import org.jboss.ws.extensions.wsrm.spi.protocol.TerminateSequence;
 
@@ -46,6 +47,7 @@
     * @param soapMessage soap message from which object will be deserialized
     */
    public static void deserialize(TerminateSequence object, Provider provider,
SOAPMessage soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }
@@ -57,6 +59,7 @@
     * @param soapMessage soap message to which object will be serialized
     */
    public static void serialize(TerminateSequence object, Provider provider, SOAPMessage
soapMessage)
+   throws ReliableMessagingException
    {
       throw new NotImplementedException();
    }

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200502/ProviderImpl.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200502/ProviderImpl.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200502/ProviderImpl.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -34,7 +34,7 @@
 {
    
    private static final String IMPLEMENTATION_VERSION =
"http://schemas.xmlsoap.org/ws/2005/02/rm";
-   private static final Constants CONSTANTS = new ConstantsImpl(IMPLEMENTATION_VERSION);
+   private static final Constants CONSTANTS = new ConstantsImpl("wsrm10",
IMPLEMENTATION_VERSION);
    private static final Provider INSTANCE = new ProviderImpl();
    
    private ProviderImpl()

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/ProviderImpl.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/ProviderImpl.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spec200702/ProviderImpl.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -34,7 +34,7 @@
 {
    
    private static final String IMPLEMENTATION_VERSION =
"http://docs.oasis-open.org/ws-rx/wsrm/200702";
-   private static final Constants CONSTANTS = new ConstantsImpl(IMPLEMENTATION_VERSION);
+   private static final Constants CONSTANTS = new
ConstantsImpl("wsrm11",IMPLEMENTATION_VERSION);
    private static final Provider INSTANCE = new ProviderImpl();
    
    private ProviderImpl()

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/Constants.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/Constants.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/Constants.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -33,6 +33,18 @@
 
    /**
     * getter
+    * @return wsrm <b>prefix</b>
+    */
+   String getPrefix();
+   
+   /**
+    * getter
+    * @return wsrm <b>namespace</b>
+    */
+   String getNamespaceURI();
+   
+   /**
+    * getter
     * @return <b>LastMessage</b> QName
     */
    QName getLastMessageQName();

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/IncompleteSequenceBehavior.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/IncompleteSequenceBehavior.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/IncompleteSequenceBehavior.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -45,17 +45,43 @@
     * A value of <b>&quot;DiscardEntireSequence&quot;</b> indicates
that the entire Sequence MUST be discarded if the
     * Sequence is closed, or terminated, when there are one or more gaps in the final
<b>SequenceAcknowledgement</b>.
     */
-   DISCARD_ENTIRE_SEQUENCE,
+   DISCARD_ENTIRE_SEQUENCE("DiscardEntireSequence"),
    
    /**
     * A value of <b>&quot;DiscardFollowingFirstGap&quot;</b>
indicates that messages in the Sequence beyond the first
     * gap MUST be discarded when there are one or more gaps in the final
<b>SequenceAcknowledgement</b>.
     */
-   DISCARD_FOLLOWING_FIRST_GAP,
+   DISCARD_FOLLOWING_FIRST_GAP("DiscardFollowingFirstGap"),
    
    /**
     * The default value of <b>&quot;NoDiscard&quot;</b> indicates
that no acknowledged messages in the Sequence will
     * be discarded.
     */
-   NO_DISCARD
+   NO_DISCARD("NoDiscard");
+   
+   private final String value;
+   
+   IncompleteSequenceBehavior(String value)
+   {
+      this.value = value;
+   }
+   
+   public String toString()
+   {
+      return value;
+   }
+   
+   /**
+    * Returns this enum instance if value string matches, <b>null</b>
otherwise
+    * @param stringValue value in the form of string
+    * @return enum or null if string not recognized
+    */
+   public static IncompleteSequenceBehavior getValue(String stringValue)
+   {
+      if (DISCARD_ENTIRE_SEQUENCE.toString().equals(stringValue)) return
DISCARD_ENTIRE_SEQUENCE;
+      if (DISCARD_FOLLOWING_FIRST_GAP.toString().equals(stringValue)) return
DISCARD_FOLLOWING_FIRST_GAP;
+      if (NO_DISCARD.toString().equals(stringValue)) return NO_DISCARD;
+      return null;
+   }
+   
 }
\ No newline at end of file

Modified:
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/Serializable.java
===================================================================
---
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/Serializable.java	2007-09-07
13:01:33 UTC (rev 4533)
+++
stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm/spi/protocol/Serializable.java	2007-09-10
08:27:49 UTC (rev 4534)
@@ -23,6 +23,8 @@
 
 import javax.xml.soap.SOAPMessage;
 
+import org.jboss.ws.extensions.wsrm.ReliableMessagingException;
+
 /**
  * This interface identifies classes that are de/serializable from/to SOAP messages
  *
@@ -35,13 +37,13 @@
     * Serialize object instance to SOAP message
     * @param soapMessage 
     */
-   void serializeTo(SOAPMessage soapMessage);
+   void serializeTo(SOAPMessage soapMessage) throws ReliableMessagingException;
    
    /**
     * Deserialize object instance from SOAP message
     * @param soapMessage
     */
-   void deserializeFrom(SOAPMessage soapMessage);
+   void deserializeFrom(SOAPMessage soapMessage) throws ReliableMessagingException;
    
    /**
     * Validate object state if everything is all right


    

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

2007

2006

[jbossws-commits] JBossWS SVN: r4534 - in stack/native/branches/ropalka/trunk/src/main/java/org/jboss/ws/extensions/wsrm: common and 5 other directories.