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

[chamikara]

chamikara    2005/01/10 23:16:42

  Modified:    sandesha/src/org/apache/sandesha/server
                        TerminateSequenceProcessor.java
  Log:
  some simple modifications
  
  Revision  Changes    Path
  1.5       +9 -3      
ws-fx/sandesha/src/org/apache/sandesha/server/TerminateSequenceProcessor.java
  
  Index: TerminateSequenceProcessor.java
  ===================================================================
  RCS file: 
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/TerminateSequenceProcessor.java,v
  retrieving revision 1.4
  retrieving revision 1.5
  diff -u -r1.4 -r1.5
  --- TerminateSequenceProcessor.java   10 Jan 2005 23:00:53 -0000      1.4
  +++ TerminateSequenceProcessor.java   11 Jan 2005 07:16:42 -0000      1.5
  @@ -33,12 +33,18 @@
   
       public boolean processMessage(RMMessageContext rmMessageContext) {
   
  -        TerminateSequence terminateSeq = rmMessageContext.getRMHeaders()
  -                .getTerminateSequence();
  -        String seqID = terminateSeq.getIdentifier().getIdentifier();
  +        TerminateSequence terminateSeq = 
rmMessageContext.getRMHeaders().getTerminateSequence();
  +        
  +        if(terminateSeq!=null && terminateSeq.getIdentifier()!=null){
  +            String seqID = terminateSeq.getIdentifier().getIdentifier();
  +        }
  +        
  +        
           //TODO
           // 
*****************************************************************************
           //storageManger.terminateSequence(sequenceID);
  +       
  +        
           return false;
       }