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

[chamikara]

chamikara    2005/02/16 03:39:03

  Modified:    sandesha/src/org/apache/sandesha/server/msgprocessors
                        CreateSequenceProcessor.java
  Log:
  some changes were done to the processMessage method
  
  Revision  Changes    Path
  1.2       +10 -5     
ws-fx/sandesha/src/org/apache/sandesha/server/msgprocessors/CreateSequenceProcessor.java
  
  Index: CreateSequenceProcessor.java
  ===================================================================
  RCS file: 
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/msgprocessors/CreateSequenceProcessor.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- CreateSequenceProcessor.java      16 Feb 2005 05:07:16 -0000      1.1
  +++ CreateSequenceProcessor.java      16 Feb 2005 11:39:03 -0000      1.2
  @@ -34,10 +34,10 @@
    */
   public class CreateSequenceProcessor implements IRMMessageProcessor {
   
  -    IStorageManager storageManger = null;
  +    IStorageManager storageManager = null;
   
  -    public CreateSequenceProcessor(IStorageManager storageManger) {
  -        this.storageManger = storageManger;
  +    public CreateSequenceProcessor(IStorageManager storageManager) {
  +        this.storageManager = storageManager;
       }
   
       public boolean processMessage(RMMessageContext rmMessageContext) throws 
RMException {
  @@ -61,7 +61,12 @@
            */
           UUIDGen uuidGen = UUIDGenFactory.getUUIDGen();
           String uuid = uuidGen.nextUUID();
  -
  +        String outUuid = uuidGen.nextUUID();
  +        
  +        storageManager.addSequence("uuid:"+uuid);
  +        storageManager.addSequence(rmMessageContext.getSequenceID());
  +        
storageManager.setTemporaryOutSequence(rmMessageContext.getSequenceID(), 
"uuid:" + outUuid );
  +        
           //TODO
           //storageManger.addSequence("uuid:"+uuid);
   
  @@ -99,7 +104,7 @@
               rmMessageContext.setOutGoingAddress(addrHeaders.getReplyTo()
                       .getAddress().toString());
               rmMessageContext.setSync(false);
  -            storageManger.addCreateSequenceResponse(rmMessageContext);
  +            storageManager.addCreateSequenceResponse(rmMessageContext);
               return false;
           }