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);
+ }
+
+ }
}