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

[chamikara]

chamikara    2005/01/10 15:02:39

  Modified:    sandesha/src/org/apache/sandesha/server/queue
                        ResponseSequenceHash.java
  Log:
  method setResponseReceived(String msgID) was added
  
  Revision  Changes    Path
  1.11      +12 -1     
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.10
  retrieving revision 1.11
  diff -u -r1.10 -r1.11
  --- ResponseSequenceHash.java 10 Jan 2005 10:49:42 -0000      1.10
  +++ ResponseSequenceHash.java 10 Jan 2005 23:02:39 -0000      1.11
  @@ -23,6 +23,7 @@
   import java.util.Set;
   import java.util.Vector;
   
  +import java_cup.version;
   
   import org.apache.sandesha.Constants;
   import org.apache.sandesha.RMMessageContext;
  @@ -43,7 +44,7 @@
    */
   public class ResponseSequenceHash {
   
  -    //following concepts was removed from priorityQueue.
  +    //following concepts was removed from highPriorityQueue.
       //This was to reduce complexity. (Since here time is also taken into
       // account)
       //private long lastProcessed;
  @@ -317,6 +318,16 @@
           }
           
           return result;
  +    }
  +    
  +    public void setResponseReceived(String msgID){
  +        Iterator it = hash.keySet().iterator();
  +        
  +        while(it.hasNext()){
  +            RMMessageContext msg = (RMMessageContext)hash.get(it.next());
  +            if(msg.getMessageID().equals(msgID))
  +                msg.setResponseReceived(true);
  +        } 
       }
       
   }