cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server/dao ServerQueueDAO.java ServerDatabaseDAO.java

[jaliya]

jaliya      2005/01/09 21:35:35

  Modified:    sandesha/src/org/apache/sandesha/server/dao
                        ServerQueueDAO.java ServerDatabaseDAO.java
  Log:
  public void markOutgoingMessageToDelete(String seqId, Long msgNo) method was 
implemented
  
  Revision  Changes    Path
  1.9       +9 -0      
ws-fx/sandesha/src/org/apache/sandesha/server/dao/ServerQueueDAO.java
  
  Index: ServerQueueDAO.java
  ===================================================================
  RCS file: 
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/dao/ServerQueueDAO.java,v
  retrieving revision 1.8
  retrieving revision 1.9
  diff -u -r1.8 -r1.9
  --- ServerQueueDAO.java       2 Dec 2004 13:18:18 -0000       1.8
  +++ ServerQueueDAO.java       10 Jan 2005 05:35:35 -0000      1.9
  @@ -379,4 +379,13 @@
           String seqId = sq.searchForSequenceId(messageId);
           return seqId;       
       }
  +    
  +    
  +    /* (non-Javadoc)
  +     * @see 
org.apache.sandesha.server.dao.IServerDAO#markOutgoingMessageToDelete(java.lang.String,
 java.lang.Long)
  +     */
  +    public void markOutgoingMessageToDelete(String seqId, Long msgNo) {
  +        ServerQueue sq = ServerQueue.getInstance();
  +        sq.markOutgoingMessageToDelete(seqId,msgNo); 
  +    }
   }
  
  
  
  1.9       +7 -0      
ws-fx/sandesha/src/org/apache/sandesha/server/dao/ServerDatabaseDAO.java
  
  Index: ServerDatabaseDAO.java
  ===================================================================
  RCS file: 
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/dao/ServerDatabaseDAO.java,v
  retrieving revision 1.8
  retrieving revision 1.9
  diff -u -r1.8 -r1.9
  --- ServerDatabaseDAO.java    2 Dec 2004 13:18:18 -0000       1.8
  +++ ServerDatabaseDAO.java    10 Jan 2005 05:35:35 -0000      1.9
  @@ -27,6 +27,13 @@
   
   public class ServerDatabaseDAO implements IServerDAO {
   
  +    /* (non-Javadoc)
  +     * @see 
org.apache.sandesha.server.dao.IServerDAO#markOutgoingMessageToDelete(java.lang.String,
 java.lang.Long)
  +     */
  +    public void markOutgoingMessageToDelete(String seqId, Long msgNo) {
  +        // TODO Auto-generated method stub
  +
  +    }
       public boolean addIncomingSequence(String sequenceId) {
           // TODO Auto-generated method stub
           return false;