cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server CreateSequenceProcessor.java

jaliya      2004/08/20 06:14:13

  Modified:    sandesha/src/org/apache/sandesha/server
                        CreateSequenceProcessor.java
  Log:
  
  
  Revision  Changes    Path
  1.5       +14 -2     
ws-fx/sandesha/src/org/apache/sandesha/server/CreateSequenceProcessor.java
  
  Index: CreateSequenceProcessor.java
  ===================================================================
  RCS file: 
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/CreateSequenceProcessor.java,v
  retrieving revision 1.4
  retrieving revision 1.5
  diff -u -r1.4 -r1.5
  --- CreateSequenceProcessor.java      18 Aug 2004 08:14:50 -0000      1.4
  +++ CreateSequenceProcessor.java      20 Aug 2004 13:14:13 -0000      1.5
  @@ -16,7 +16,9 @@
    */
   package org.apache.sandesha.server;
   
  +import org.apache.axis.AxisFault;
   import org.apache.axis.Message;
  +import org.apache.axis.MessageContext;
   import org.apache.axis.components.uuid.UUIDGen;
   import org.apache.axis.components.uuid.UUIDGenFactory;
   import org.apache.axis.message.SOAPEnvelope;
  @@ -55,19 +57,29 @@
                        //Create the SOAPEnvelop to send and set it to the 
resEnv of rmMessageCotext.
                        SOAPEnvelope resEnvelope =
                                
EnvelopeCreator.createCreateSequenceResponseEnvelope(uuid, rmMessageContext);
  +                                                     
  +                             //MessageContext msgContext= 
rmMessageContext.getMsgContext();
  +                             //msgContext.setResponseMessage(new 
Message(resEnvelope));
  +                             //rmMessageContext.setMsgContext(msgContext);
   
  -                     rmMessageContext.getMsgContext().setResponseMessage(new 
Message(resEnvelope));
  +                     
                        //Set the message type.
                        
rmMessageContext.setMessageType(org.apache.sandesha.Constants.MSG_TYPE_CREATE_SEQUENCE_RESPONSE);
  -
  +                     
                        //We have some synchronous stuff here
                        if 
(addrHeaders.getReplyTo().getAddress().toString().equals(Constants.NS_URI_ANONYMOUS))
 {
                                //Do we need anything here??
                                //Inform that we have a synchronous response.
  +                             
rmMessageContext.getMsgContext().setResponseMessage(new Message(resEnvelope));
                                return true;
                        } else {
                                //FIX THIS FIX THIS
                                //This should be 
storageManger.addCreateSequenceResponse();
  +     
  +                             MessageContext msgContext = new 
MessageContext(rmMessageContext.getMsgContext().getAxisEngine());
  +                             msgContext.setResponseMessage(new 
Message(resEnvelope));
  +                             rmMessageContext.setMsgContext(msgContext);
  +                             
                                
rmMessageContext.setOutGoingAddress(addrHeaders.getReplyTo().getAddress().toString());
                                
storageManger.addCreateSequenceResponse(rmMessageContext);
                                return false;