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

[chamikara]

chamikara    2005/02/17 22:35:11

  Modified:    sandesha/src/org/apache/sandesha/storage/dao
                        ISandeshaDAO.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       +9 -0      
ws-fx/sandesha/src/org/apache/sandesha/storage/dao/ISandeshaDAO.java
  
  Index: ISandeshaDAO.java
  ===================================================================
  RCS file: 
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/storage/dao/ISandeshaDAO.java,v
  retrieving revision 1.1
  retrieving revision 1.2
  diff -u -r1.1 -r1.2
  --- ISandeshaDAO.java 16 Feb 2005 08:03:13 -0000      1.1
  +++ ISandeshaDAO.java 18 Feb 2005 06:35:11 -0000      1.2
  @@ -17,6 +17,7 @@
   package org.apache.sandesha.storage.dao;
   
   import org.apache.sandesha.RMMessageContext;
  +import org.apache.sandesha.storage.queue.SandeshaQueue;
   
   import java.util.Set;
   
  @@ -91,4 +92,12 @@
       public void addLowPriorityMessage(RMMessageContext msg);
   
       public RMMessageContext getNextLowPriorityMessageContextToSend();
  +    
  +    public void addSendMsgNo(String seqId,long msgNo);
  +    
  +    public boolean isSentMsg(String seqId,long msgNo);
  +    
  +    public boolean hasLastMsgReceived(String seqId);
  +
  +    public long getLastMsgNo(String seqId);
   }
  \ No newline at end of file