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

[chamikara]

chamikara    2005/01/10 23:21:03

  Modified:    sandesha/src/org/apache/sandesha/server/queue
                        ResponseSequenceHash.java
  Log:
  added methods for supporting terminate seq message
  
  Revision  Changes    Path
  1.12      +39 -0     
ws-fx/sandesha/src/org/apache/sandesha/server/queue/ResponseSequenceHash.java
  
  Index: ResponseSequenceHash.java
  ===================================================================
  RCS file: 
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/queue/ResponseSequenceHash.java,v
  retrieving revision 1.11
  retrieving revision 1.12
  diff -u -r1.11 -r1.12
  --- ResponseSequenceHash.java 10 Jan 2005 23:02:39 -0000      1.11
  +++ ResponseSequenceHash.java 11 Jan 2005 07:21:02 -0000      1.12
  @@ -330,4 +330,43 @@
           } 
       }
       
  +    public void setAckReceived(String msgID){
  +        Iterator it = hash.keySet().iterator();
  +        
  +        while(it.hasNext()){
  +            RMMessageContext msg = (RMMessageContext)hash.get(it.next());
  +            if(msg.getMessageID().equals(msgID))
  +                msg.setAckReceived(true);
  +        } 
  +    }
  +    
  +
  +    
  +    public boolean isAckComplete(){
  +        if(!hasLastMessage())
  +            return false;
  +        
  +        Iterator it = hash.keySet().iterator();
  +        
  +        while(it.hasNext()){
  +            RMMessageContext msg = (RMMessageContext) it.next();
  +            if(!msg.isAckReceived())
  +                return false;
  +        }
  +        
  +        return true;
  +    }
  +    
  +    private boolean hasLastMessage(){
  +        Iterator it = hash.keySet().iterator();
  +        
  +        while(it.hasNext()){
  +            RMMessageContext msg = (RMMessageContext) it.next();
  +            if(msg.isLastMessage())
  +                return true;
  +        }
  +        
  +        return false;
  +    }
  +    
   }