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

[chamikara]

chamikara    2005/01/10 23:19:44

  Modified:    sandesha/src/org/apache/sandesha/server/dao
                        ServerQueueDAO.java
  Log:
  implemented method setAckReceived
  
  Revision  Changes    Path
  1.12      +24 -1     
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.11
  retrieving revision 1.12
  diff -u -r1.11 -r1.12
  --- ServerQueueDAO.java       10 Jan 2005 23:02:00 -0000      1.11
  +++ ServerQueueDAO.java       11 Jan 2005 07:19:44 -0000      1.12
  @@ -349,6 +349,7 @@
   
       }
   
  +
       /*
        * (non-Javadoc)
        * 
  @@ -433,4 +434,26 @@
        }
   
       }
  -}
  \ No newline at end of file
  +    
  +    
  +    /* (non-Javadoc)
  +     * @see 
org.apache.sandesha.server.dao.IServerDAO#getNextLowPriorityMessageContextToSend()
  +     */
  +    public RMMessageContext getNextLowPriorityMessageContextToSend() {
  +        
  +        ServerQueue sq = ServerQueue.getInstance();
  +        try{
  +            return sq.nextLowPriorityMessageToSend();
  +        }catch(Exception e){
  +            log.error(e);
  +        }
  +        
  +        return null;
  +    }
  +    
  +    public void setAckReceived(RMMessageContext responseMsg) {
  +        ServerQueue sq = ServerQueue.getInstance();
  +        sq.setAckReceived(responseMsg);
  +
  +    }
  +}