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>"DiscardEntireSequence"</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>"DiscardFollowingFirstGap"</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>"NoDiscard"</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