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

[chamikara]

chamikara    2005/01/10 15:02:00

  Modified:    sandesha/src/org/apache/sandesha/server/dao
                        ServerQueueDAO.java
  Log:
  Added methods of the ISererDAO were implemented
  
  Revision  Changes    Path
  1.11      +20 -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.10
  retrieving revision 1.11
  diff -u -r1.10 -r1.11
  --- ServerQueueDAO.java       10 Jan 2005 05:43:31 -0000      1.10
  +++ ServerQueueDAO.java       10 Jan 2005 23:02:00 -0000      1.11
  @@ -413,4 +413,24 @@
           
           return result;
       }
  +    
  +    public void setResponseReceived(RMMessageContext msg){
  +        ServerQueue sq = ServerQueue.getInstance();
  +        sq.setResponseReceived(msg);
  +    }
  +    
  +    
  +    /* (non-Javadoc)
  +     * @see 
org.apache.sandesha.server.dao.IServerDAO#addLowPriorityMessage(org.apache.sandesha.RMMessageContext)
  +     */
  +    public void addLowPriorityMessage(RMMessageContext msg) {
  +        ServerQueue sq = ServerQueue.getInstance();
  +      
  +        try{
  +            sq.addLowPriorityMessage(msg);
  +     } catch (QueueException e) {
  +         log.error(e);
  +     }
  +
  +    }
   }