Dear Shandesha Committers,

Please accept this patch which enables CreateSequenceResponse message generation in RMMessgeCreator class.

Thanks,
Sanka Samaranayake.
Index: RMMsgCreator.java
===================================================================
--- RMMsgCreator.java   (revision 240397)
+++ RMMsgCreator.java   (working copy)
@@ -17,9 +17,51 @@
 
 package org.apache.sandesha2;
 
+import org.apache.axis2.addressing.EndpointReference;
+import org.apache.axis2.addressing.om.AddressingHeaders;
+import org.apache.axis2.om.OMAbstractFactory;
+import org.apache.axis2.soap.SOAPEnvelope;
+import org.apache.sandesha2.msgreceivers.RMMessageReceiver;
+import org.apache.sandesha2.wsrm.Accept;
+import org.apache.sandesha2.wsrm.AcksTo;
+import org.apache.sandesha2.wsrm.CreateSequence;
+import org.apache.sandesha2.wsrm.CreateSequenceResponse;
+import org.apache.sandesha2.wsrm.IOMRMElement;
+import org.apache.sandesha2.wsrm.Identifier;
+
 /**
  * @author
  */
 public class RMMsgCreator {
 
+       public RMMsgContext createCreateSeqResponseMsg (RMMsgContext 
createSeqMsg) {
+               IOMRMElement messagePart = 
+                               
createSeqMsg.getMessagePart(Constants.MESSAGE_PART_CREATE_SEQ);
+               AddressingHeaders addrHeaders = 
+                       (AddressingHeaders) 
createSeqMsg.getMessagePart(Constants.MESSAGE_PART_ADDR_HEADERS);
+       
+               CreateSequence cs = (CreateSequence) messagePart;
+               CreateSequenceResponse response = new CreateSequenceResponse();
+               
+               Identifier identifier = new Identifier();
+               // TODO : set the an appropriate id 
+               identifier.setIndentifer("94-(0)11-2237434");
+               response.setIdentifier(identifier);
+               
+               Accept accept = new Accept();
+               EndpointReference wsaTo = addrHeaders.getWsaTo();
+               AcksTo acksTo = new AcksTo(wsaTo);
+               accept.setAcksTo(acksTo);
+               response.setAccept(accept);
+               
+               RMMsgContext msgContext = new RMMsgContext();
+               
msgContext.setMessagePart(Constants.MESSAGE_PART_CREATE_SEQ_RESPONSE, response);
+               return msgContext;
+       }
+       
+       
+       
+       private SOAPEnvelope getSOAPEnvelope() {
+               return 
OMAbstractFactory.getSOAP11Factory().getDefaultEnvelope();
+       }
 }

---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]

Reply via email to