You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by sn...@apache.org on 2004/06/05 12:18:00 UTC
cvs commit: ws-fx/sandesha/src/org/apache/sandesha/ws/rm/handlers RMServerRequestHandler.java
snimalan 2004/06/05 03:18:00
Modified: sandesha/src/org/apache/sandesha/ws/rm AckRequested.java
SequenceAcknowledgement.java CreateSequence.java
sandesha/src/org/apache/sandesha/ws/rm/handlers
RMServerRequestHandler.java
Log:
SequenceAcknowledgement, AckRequest classes Modified to send Header elements with mustunderstand = "1"
RMServerReuqestHandler modified so that, that will read every header elements and setProccessed to true.
Revision Changes Path
1.10 +1 -0 ws-fx/sandesha/src/org/apache/sandesha/ws/rm/AckRequested.java
Index: AckRequested.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/ws/rm/AckRequested.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -u -r1.9 -r1.10
--- AckRequested.java 7 May 2004 15:35:18 -0000 1.9
+++ AckRequested.java 5 Jun 2004 10:17:59 -0000 1.10
@@ -107,6 +107,7 @@
// .setActor(null);
headerElement.setActor(null);
headerElement.setName("AckRequested");
+ headerElement.setMustUnderstand(true);
if (identifier != null) {
identifier.toSOAPEnvelope(headerElement);
1.9 +1 -0 ws-fx/sandesha/src/org/apache/sandesha/ws/rm/SequenceAcknowledgement.java
Index: SequenceAcknowledgement.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/ws/rm/SequenceAcknowledgement.java,v
retrieving revision 1.8
retrieving revision 1.9
diff -u -r1.8 -r1.9
--- SequenceAcknowledgement.java 7 May 2004 15:35:18 -0000 1.8
+++ SequenceAcknowledgement.java 5 Jun 2004 10:17:59 -0000 1.9
@@ -131,6 +131,7 @@
headerElement.setActor(null);
headerElement.setName("SequenceAcknowledgement");
+ headerElement.setMustUnderstand(true);
Iterator iterator = ackRanges.iterator();
1.9 +1 -0 ws-fx/sandesha/src/org/apache/sandesha/ws/rm/CreateSequence.java
Index: CreateSequence.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/ws/rm/CreateSequence.java,v
retrieving revision 1.8
retrieving revision 1.9
diff -u -r1.8 -r1.9
--- CreateSequence.java 7 May 2004 15:35:18 -0000 1.8
+++ CreateSequence.java 5 Jun 2004 10:17:59 -0000 1.9
@@ -84,6 +84,7 @@
(SOAPBodyElement) env.getBody().addBodyElement(name);
bodyElement.setName("CreateSequence");
+
return env;
}
1.10 +10 -0 ws-fx/sandesha/src/org/apache/sandesha/ws/rm/handlers/RMServerRequestHandler.java
Index: RMServerRequestHandler.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/ws/rm/handlers/RMServerRequestHandler.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -u -r1.9 -r1.10
--- RMServerRequestHandler.java 7 May 2004 15:18:21 -0000 1.9
+++ RMServerRequestHandler.java 5 Jun 2004 10:18:00 -0000 1.10
@@ -16,8 +16,11 @@
*/
package org.apache.sandesha.ws.rm.handlers;
+import java.util.Iterator;
+
import org.apache.axis.AxisFault;
import org.apache.axis.MessageContext;
+import org.apache.axis.message.SOAPHeaderElement;
import org.apache.sandesha.Constants;
import javax.xml.soap.SOAPException;
@@ -45,6 +48,13 @@
public void invoke(MessageContext msgContext) throws AxisFault {
try {
+ Iterator iterator=msgContext.getRequestMessage().getSOAPEnvelope().getHeader().getChildElements();
+ SOAPHeaderElement elements;
+ while(iterator.hasNext()){
+ elements=(SOAPHeaderElement) iterator.next();
+ elements.setProcessed(true);
+ }
+
setPropertyToMessageContext(
msgContext,
Constants.ENV_RM_REQUEST_HEADERS);