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

jaliya      2004/08/27 20:04:11

  Modified:    sandesha/src/org/apache/sandesha/server
                        CreateSequenceResponseProcessor.java
  Log:
  Implemented the CreateSequenceResponse Processor. Still the deletion of the 
messages is not done.
  PR:
  Obtained from:
  Submitted by: 
  Reviewed by:  
  CVS: ----------------------------------------------------------------------
  CVS: PR:
  CVS:   If this change addresses a PR in the problem report tracking
  CVS:   database, then enter the PR number(s) here.
  CVS: Obtained from:
  CVS:   If this change has been taken from another system, such as NCSA,
  CVS:   then name the system in this line, otherwise delete it.
  CVS: Submitted by:
  CVS:   If this code has been contributed to Apache by someone else; i.e.,
  CVS:   they sent us a patch or a new module, then include their name/email
  CVS:   address here. If this is your work then delete this line.
  CVS: Reviewed by:
  CVS:   If we are doing pre-commit code reviews and someone else has
  CVS:   reviewed your changes, include their name(s) here.
  CVS:   If you have not had it reviewed then delete this line.
  
  Revision  Changes    Path
  1.3       +4 -6      
ws-fx/sandesha/src/org/apache/sandesha/server/CreateSequenceResponseProcessor.java
  
  Index: CreateSequenceResponseProcessor.java
  ===================================================================
  RCS file: 
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/CreateSequenceResponseProcessor.java,v
  retrieving revision 1.2
  retrieving revision 1.3
  diff -u -r1.2 -r1.3
  --- CreateSequenceResponseProcessor.java      11 Aug 2004 10:47:51 -0000      
1.2
  +++ CreateSequenceResponseProcessor.java      28 Aug 2004 03:04:11 -0000      
1.3
  @@ -27,10 +27,10 @@
    *
    */
   public class CreateSequenceResponseProcessor implements IRMMessageProcessor {
  -     IStorageManager storageManger=null;
  +     IStorageManager storageManager=null;
        
        public CreateSequenceResponseProcessor(IStorageManager storageManger){
  -             this.storageManger=     storageManger;
  +             this.storageManager=    storageManger;
        }
        
   
  @@ -41,10 +41,8 @@
                //CHEK CHEK 
*********************************************************************************
                RelatesTo relatesTo = (RelatesTo) 
rmMessageContext.getAddressingHeaders().getRelatesTo().get(0);
                String sequenceID = createSeqRes.getIdentifier().toString();
  -             
  -             //storageManger.setResponseSequence(String relatesTo,String 
sequenceID);
  -             //storageManger.setResponseSequence(relatesTo.getId 
etc..,sequenceID);
  -
  +             
storageManager.setApprovedOutSequence(sequenceID,relatesTo.getURI().getFragment().toString());
  +     
                //Delete the CreateSequence request message in the create 
sequence request queue. 
                //storageManger.removeCreateSequenceRequest(String messageID)