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 ch...@apache.org on 2005/02/18 07:37:37 UTC
cvs commit: ws-fx/sandesha/src/org/apache/sandesha/storage/dao SandeshaQueueDAO.java
chamikara 2005/02/17 22:37:37
Modified: sandesha/src/org/apache/sandesha/storage/dao
SandeshaQueueDAO.java
Log:
Fololowing methods were added
public void addSendMsgNo(String seqId,long msgNo);
public boolean isSentMsg(String seqId,long msgNo);
public boolean hasLastMsgReceived(String seqId);
public long getLastMsgNo(String seqId);
Revision Changes Path
1.2 +21 -0 ws-fx/sandesha/src/org/apache/sandesha/storage/dao/SandeshaQueueDAO.java
Index: SandeshaQueueDAO.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/storage/dao/SandeshaQueueDAO.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- SandeshaQueueDAO.java 16 Feb 2005 08:03:13 -0000 1.1
+++ SandeshaQueueDAO.java 18 Feb 2005 06:37:37 -0000 1.2
@@ -21,6 +21,7 @@
import org.apache.sandesha.RMMessageContext;
import org.apache.sandesha.storage.queue.QueueException;
import org.apache.sandesha.storage.queue.SandeshaQueue;
+import org.apache.sandesha.storage.queue.SequenceHash;
import java.util.Random;
import java.util.Set;
@@ -455,4 +456,24 @@
SandeshaQueue sq = SandeshaQueue.getInstance();
sq.setAckReceived(seqId, msgNo);
}
+
+ public void addSendMsgNo(String seqId,long msgNo){
+ SandeshaQueue sq = SandeshaQueue.getInstance();
+ sq.addSendMsgNo(seqId,msgNo);
+ }
+
+ public boolean isSentMsg(String seqId,long msgNo){
+ SandeshaQueue sq = SandeshaQueue.getInstance();
+ return sq.isSentMsg(seqId,msgNo);
+ }
+
+ public boolean hasLastMsgReceived(String seqId){
+ SandeshaQueue sq = SandeshaQueue.getInstance();
+ return sq.hasLastMsgReceived(seqId);
+ }
+
+ public long getLastMsgNo(String seqId){
+ SandeshaQueue sq = SandeshaQueue.getInstance();
+ return sq.getLastMsgNo(seqId);
+ }
}