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

jaliya      2004/08/20 06:13:29

  Modified:    sandesha/src/org/apache/sandesha/server
                        AcknowledgementProcessor.java
  Log:
  no message
  
  Revision  Changes    Path
  1.4       +38 -3     
ws-fx/sandesha/src/org/apache/sandesha/server/AcknowledgementProcessor.java
  
  Index: AcknowledgementProcessor.java
  ===================================================================
  RCS file: 
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/AcknowledgementProcessor.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -r1.3 -r1.4
  --- AcknowledgementProcessor.java     18 Aug 2004 08:14:39 -0000      1.3
  +++ AcknowledgementProcessor.java     20 Aug 2004 13:13:29 -0000      1.4
  @@ -24,6 +24,7 @@
   import javax.xml.soap.SOAPEnvelope;
   
   import org.apache.axis.Message;
  +import org.apache.axis.MessageContext;
   import org.apache.sandesha.Constants;
   import org.apache.sandesha.EnvelopeCreator;
   import org.apache.sandesha.IStorageManager;
  @@ -90,23 +91,57 @@
   
                SOAPEnvelope ackEnvelope = 
EnvelopeCreator.createAcknowledgementEnvelope(rmMessageContext, ackRangeVector);
                //Add the envelope to the response message of the 
messageContext.
  -             rmMessageContext.getMsgContext().setResponseMessage(new 
Message(ackEnvelope));
  +             //rmMessageContext.getMsgContext().setResponseMessage(new 
Message(ackEnvelope));
                
rmMessageContext.setMessageType(Constants.MSG_TYPE_ACKNOWLEDGEMENT);
  +             
  +             
  +                                      
////////////////////////////////////////////////////////////////////////
  +                                      //////////////////////////////NEED TO 
CLEAN THIS PART///////////////////
  +                             
  +                                       RMMessageContext rmMsgContext= new 
RMMessageContext();
  +                                       
rmMsgContext.setAddressingHeaders(rmMessageContext.getAddressingHeaders());
  +                                       
rmMsgContext.setMessageID(rmMessageContext.getMessageID());
  +                                       
rmMsgContext.setObj(rmMessageContext.getObj());
  +                                       
rmMsgContext.setReqEnv(rmMessageContext.getReqEnv());
  +                                       
rmMsgContext.setResEnv(rmMessageContext.getResEnv());
  +                                       
rmMsgContext.setRMHeaders(rmMessageContext.getRMHeaders());
  +                                       
rmMsgContext.setSequenceID(rmMessageContext.getSequenceID());
  +                                       
rmMsgContext.setOutGoingAddress(rmMessageContext.getOutGoingAddress());
  +                             
  +                                       Message reqMsg= new 
Message(rmMessageContext.getMsgContext().getRequestMessage());
  +                                       MessageContext msgContext = new 
MessageContext(rmMessageContext.getMsgContext().getAxisEngine());
  +                             
  +                                       msgContext = 
MessageContext.getCurrentContext();
  +                                       msgContext.setRequestMessage(reqMsg);
  +                                     
  +                                       
rmMsgContext.setMsgContext(msgContext);
  +                                       
  +                                       msgContext.setResponseMessage(new 
Message(ackEnvelope));
  +                                   
rmMsgContext.setOutGoingAddress(rmMessageContext.getAddressingHeaders().getFrom().getAddress().toString());
  +                                       
rmMsgContext.setMessageType(Constants.MSG_TYPE_ACKNOWLEDGEMENT);
  +                                       
rmMsgContext.setMsgContext(msgContext);
  +                                                                     
  +                                       
////////////////////////////////////////////////////////////////////////
  +             
   
                if ((rmMessageContext
                        .getAddressingHeaders()
                        .getFrom()
                        .getAddress()
                        .toString()
  -                     
.equals(org.apache.axis.message.addressing.Constants.NS_URI_ANONYMOUS))) {
  +                     
.equals(org.apache.axis.message.addressing.Constants.NS_URI_ANONYMOUS))==true) {
                        //Now we have synchronized ack.
                        
//rmMessageContext.getMsgContext().setResponseMessage(new Message(ackEnvelope));
  +                     rmMessageContext.getMsgContext().setResponseMessage(new 
Message(ackEnvelope));
                        return true;
                } else {
  +                     
  +                     ////////////////////////////////NEED TO CLEAN THIS 
PART///////////////////////////////////
  +     
                        //Store the asynchronize ack in the queue.
                        //The name for this queue is not yet fixed.
                        //RENAME insertAcknowledgement(rmMessageContext)
  -                     storageManger.addAcknowledgement(rmMessageContext);
  +                     storageManger.addAcknowledgement(rmMsgContext);
                        return false;
                }