cvs commit: ws-fx/sandesha/src/org/apache/sandesha/storage/dao SandeshaQueueDAO.java

[chamikara]

chamikara    2005/02/17 22:37:37

  Modified:    sandesha/src/org/apache/sandesha/storage/dao
                        SandeshaQueueDAO.java
  Log:
   Fololowing methods were added
  
   public void addSendMsgNo(String seqId,long msgNo);
  
    public boolean isSentMsg(String seqId,long msgNo);
  
    public boolean hasLastMsgReceived(String seqId);
  
    public long getLastMsgNo(String seqId);
  
  Revision  Changes    Path
  1.2       +21 -0     
ws-fx/sandesha/src/org/apache/sandesha/storage/dao/SandeshaQueueDAO.java
  
  Index: SandeshaQueueDAO.java
  ===================================================================
  RCS file: 
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/storage/dao/SandeshaQueueDAO.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- SandeshaQueueDAO.java     16 Feb 2005 08:03:13 -0000      1.1
  +++ SandeshaQueueDAO.java     18 Feb 2005 06:37:37 -0000      1.2
  @@ -21,6 +21,7 @@
   import org.apache.sandesha.RMMessageContext;
   import org.apache.sandesha.storage.queue.QueueException;
   import org.apache.sandesha.storage.queue.SandeshaQueue;
  +import org.apache.sandesha.storage.queue.SequenceHash;
   
   import java.util.Random;
   import java.util.Set;
  @@ -455,4 +456,24 @@
           SandeshaQueue sq = SandeshaQueue.getInstance();
           sq.setAckReceived(seqId, msgNo);
       }
  +    
  +    public void addSendMsgNo(String seqId,long msgNo){
  +     SandeshaQueue sq = SandeshaQueue.getInstance();
  +     sq.addSendMsgNo(seqId,msgNo);
  +    }
  +    
  +    public boolean isSentMsg(String seqId,long msgNo){
  +     SandeshaQueue sq = SandeshaQueue.getInstance();
  +     return sq.isSentMsg(seqId,msgNo);
  +    }
  +    
  +    public boolean hasLastMsgReceived(String seqId){
  +     SandeshaQueue sq = SandeshaQueue.getInstance();
  +     return sq.hasLastMsgReceived(seqId);   
  +    }
  +
  +    public long getLastMsgNo(String seqId){
  +     SandeshaQueue sq = SandeshaQueue.getInstance();
  +     return sq.getLastMsgNo(seqId);
  +    }
   }