You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ja...@apache.org on 2004/09/06 10:21:24 UTC
cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server/dao ServerQueueDAO.java
jaliya 2004/09/06 01:21:24
Modified: sandesha/src/org/apache/sandesha/server/dao
ServerQueueDAO.java
Log:
Two methods void moveResponseMessageToBin(String sequenceId,Long msgNo);
void removeCreateSequenceMsg(String messageId); were implemented
Revision Changes Path
1.3 +21 -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.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- ServerQueueDAO.java 20 Aug 2004 13:14:35 -0000 1.2
+++ ServerQueueDAO.java 6 Sep 2004 08:21:23 -0000 1.3
@@ -325,4 +325,24 @@
return sq.getSequenceOfOutSequence(outsequenceId);
}
-}
+ /* (non-Javadoc)
+ * @see org.apache.sandesha.server.dao.IServerDAO#moveResponseMessageToBin(java.lang.String, java.lang.Long)
+ */
+ public void moveResponseMessageToBin(String sequenceId, Long msgNo) {
+ // TODO Auto-generated method stub
+ ServerQueue sq = ServerQueue.getInstance();
+ sq.moveResponseMsgToBin(sequenceId,msgNo);
+
+ }
+
+ /* (non-Javadoc)
+ * @see org.apache.sandesha.server.dao.IServerDAO#removeCreateSequenceMsg(java.lang.String)
+ */
+ public void removeCreateSequenceMsg(String messageId) {
+ // TODO Auto-generated method stub
+ ServerQueue sq = ServerQueue.getInstance();
+ sq.movePriorityMsgToBin(messageId);
+
+ }
+
+}
\ No newline at end of file