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/05/19 01:11:25 UTC
cvs commit: ws-fx/sandesha/src/org/apache/sandesha/storage/dao ISandeshaDAO.java SandeshaDatabaseDAO.java SandeshaQueueDAO.java
chamikara 2005/05/18 16:11:25
Modified: sandesha/src/org/apache/sandesha/storage/dao
ISandeshaDAO.java SandeshaDatabaseDAO.java
SandeshaQueueDAO.java
Log:
Javadoc comments were added.
Revision Changes Path
1.12 +205 -3 ws-fx/sandesha/src/org/apache/sandesha/storage/dao/ISandeshaDAO.java
Index: ISandeshaDAO.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/storage/dao/ISandeshaDAO.java,v
retrieving revision 1.11
retrieving revision 1.12
diff -u -r1.11 -r1.12
--- ISandeshaDAO.java 14 May 2005 06:52:31 -0000 1.11
+++ ISandeshaDAO.java 18 May 2005 23:11:25 -0000 1.12
@@ -28,108 +28,310 @@
*/
public interface ISandeshaDAO {
+
+ /**
+ * This adds a new entry in the storage to to hold messages of a perticular
+ * sequence that come in to the sandesha server/client
+ */
boolean addIncomingSequence(String sequenceId);
+
+ /**
+ * This adds a entry in the storage for holding the messages of the given outgoing
+ * sequence.
+ */
boolean addOutgoingSequence(String sequenceId);
+
+ /**
+ * Adds a priority message (e.g. create seq) to the queue. These will be sent
+ * before other messages like application requests.
+ */
boolean addPriorityMessage(RMMessageContext message);
+
+ /**
+ * This checks the priority messages to see weather there is any one to
+ * be sent (either for the first time or a retransmission)
+ */
RMMessageContext getNextPriorityMessageContextToSend();
+
+ /**
+ * This adds a incoming message to a area belonging to the given sequence in the
+ * queue.
+ */
boolean addMessageToIncomingSequence(String sequenceId, Long msgNo,
RMMessageContext rmMessageContext);
+
+ /**
+ * This adds the given message to the given sequence.
+ */
boolean addMessageToOutgoingSequence(String sequenceId,
RMMessageContext rmMessageContext);
+
+ /**
+ * This checks weather there is a entry for the given incoming sequence in
+ * the queue.
+ */
boolean isIncomingSequenceExists(String sequenceId);
+
+ /**
+ * Checks weather a entry for the given outgoing sequence exists in
+ * the queue.
+ */
boolean isOutgoingSequenceExists(String sequenceId);
+
+
+ /**
+ * This checks in the given incoming sequence to see weather a message of
+ * the given message no exists
+ */
boolean isIncomingMessageExists(String sequenceId, Long msgNo);
+
+ /**
+ * This tries to get the next message to be sent from the given outgoing sequence
+ * If these is no message to be sent in the given sequence, null will be returned.
+ */
RMMessageContext getNextMsgContextToProcess(String sequenceId);
+
+ /**
+ * Gets the next possible message to be sent from the queue.
+ */
RMMessageContext getNextOutgoingMsgContextToSend();
+ /**
+ * This is used to randomize the process of message sending. Otherwise messages of some
+ * sequence will not be sent while some other sequences will very easily be able to send all
+ * their messages.
+ */
String getRandomSeqIdToProcess();
+
+ /**
+ * This reutns a set of message numbers with all the message numbers of
+ * incoming sequence.
+ */
Set getAllReceivedMsgNumsOfIncomingSeq(String sequenceId);
+
+ /**
+ * Gives a set of message numbers of messages present in the queue for
+ * the given sequence.
+ */
Set getAllReceivedMsgNumsOfOutgoingSeq(String sequenceId);
+
+ /**
+ * This sets the outgoing sequence. Here seqId is the entry in the queue
+ * that we hope to hold the messages of a perticular sequence. outseqid is the
+ * actual sequence id (i.e. uuid). That will be set within the wsrm:sequence field of
+ * this message. (remember that we may not have received this actual outgoing sequence id
+ * by the time we start to store outgoing messages).
+ */
void setOutSequence(String sequenceId, String outSequenceId);
+
+ /**
+ * This sets a flag in the queue to indicate that the outSequence of the perticular message set
+ * (stored with the id seqId) has been set correctly. The value in outSequence may be wrong
+ * before the sender gets the create seq. response. After getting this and after setting the
+ * out sequence correctly using the previous method, this flag will be set to true. Only then these
+ * messages thould be send to the sender.
+ */
void setOutSequenceApproved(String sequenceID, boolean approved);
+
+ /**
+ * this gives the seqId which is used to hold the messages of which the
+ * outsequence entry has been set to the value outsequenceId.
+ */
String getSequenceOfOutSequence(String outsequenceId);
+
+ /**
+ * Removes the outgoing message from the sequence entry to the bin.
+ * (so that they will not be re-transmitted)
+ */
void moveOutgoingMessageToBin(String sequenceId, Long msgNo);
+ /**
+ * This checks the priority queue for a message if given messageid and
+ * moves it to the bin
+ */
void removeCreateSequenceMsg(String messageId);
+ /**
+ * This gives the next message number, outgoing storage of the given sequence
+ * esxpects. Actually this will be used by storage managers to obtain the message
+ * number that should be put to the next application message.
+ */
long getNextOutgoingMessageNumber(String sequenceId);
+ /**
+ * When the messageId of therequest message (e.g. from relates to) and the sequence id
+ * is given this will give the response message.
+ */
public RMMessageContext checkForResponseMessage(String requestId, String seqId);
+ /**
+ *This checks weather a message with given message id is present in the request sequence
+ *given.
+ */
public boolean isRequestMessagePresent(String sequenceId, String msgId);
+ /**
+ * Tries to give the sequence id of the outgoing message with the given message id
+ */
public String searchForSequenceId(String messageId);
+ /**
+ * This outgoing message will be marked as deleted.
+ * i.e. it will not be re-transmitted
+ */
public void markOutgoingMessageToDelete(String sequenceId, Long msgNumber);
+ /**
+ * Should check weather all the outgoing messages have received acks. Otherwise
+ * should return false.
+ */
public boolean compareAcksWithSequence(String sequenceId);
+ /**
+ *Acks the storage to set the request message relating to the response message passed as a
+ *parameter as got response.
+ */
public void setResponseReceived(RMMessageContext msg);
+ /**
+ * Tells to the rtorage that the given message of given sequence was acked.
+ */
public void setAckReceived(String seqId, long msgNo);
+ /**
+ * Adds a low priority message to the storage (e.g. terminate sequence).
+ * These messages are axpected to be sent after sending all the other messages
+ * of the given sequence (but it is not a must)
+ */
public void addLowPriorityMessage(RMMessageContext msg);
+ /**
+ * Asks the storage for the next low priority message (if there is any)
+ */
public RMMessageContext getNextLowPriorityMessageContextToSend();
+ /**
+ * The message will be added to a sent list (the list holds the
+ * messages that were sent at least once)
+ */
public void addSendMsgNo(String seqId, long msgNo);
+ /**
+ * Asks from the storage weather the given message has been sent at
+ * least once
+ */
public boolean isSentMsg(String seqId, long msgNo);
+
+ /**
+ * Asks weather the storage has got the last message of the outgoing sequence.
+ */
public boolean hasLastOutgoingMsgReceived(String seqId);
+ /**
+ * Asks for the message no. of the last message of the given sequence.
+ */
public long getLastOutgoingMsgNo(String seqId);
+ /**
+ * Can be used to ckeck weather the last message has been received in the
+ * incoming sequence.
+ */
public boolean hasLastIncomingMsgReceived(String seqId);
+ /**
+ * Asks for the last message of the incoming sequence (if it has been received)
+ */
public long getLastIncomingMsgNo(String seqId);
+ /**
+ * When a server or client sends a create sequence, it will be marked from this method.
+ * But the actual resources will be allocated only when the first message arrives.
+ */
public void addRequestedSequence(String seqId);
+ /**
+ * Check weather the given sequence id is one of the requested once (see 'addRequestedSequence')
+ */
public boolean isRequestedSeqPresent(String seqId);
- //The client side will not be able to have sequenceId as a key for storing request messages.
- //Since it may be not known when the user adds first message.
- //Two methods below will be used to get this key from the actual sequenceid.
+ /**The client side will not be able to have sequenceId as a key for storing request messages.
+ *Since it may be not known when the user adds first message.
+ *This asks for that key, giving sequence id of incoming messages.
+ */
public String getKeyFromIncomingSequenceId(String incomingSeqID);
+ /**
+ *This asks for the above key (the key used to hold messages) given the outgoing sequece id.
+ */
public String getKeyFromOutgoingSequenceId(String outgoingSeqID);
+ /**
+ * Gets a iterator of all outgoing sequence ids.
+ */
public Iterator getAllOutgoingSequences();
+ /**
+ * Sets this after sending the terminate sequence message.
+ */
public void setTerminateSend(String seqId);
+ /**
+ * Sets a incoming sequence of messages as terminate received.
+ */
public void setTerminateReceived(String seqId);
+ /**
+ * Checks weather the terminate message of all out going sequences have been sent.
+ */
public boolean isAllOutgoingTerminateSent();
+ /**
+ * Use this to check weather the terminate message of all sequences (incoming) has
+ * been received.
+ */
public boolean isAllIncommingTerminateReceived();
public String getFirstCreateSequenceMsgId(String createSeqId);
+ /**
+ * Set the acks to of the given sequence.
+ */
public void setAcksTo(String seqId,String acksTo);
+ /**
+ * gets the acksTo value
+ */
public String getAcksTo(String seqId);
+ /**
+ * Sets the offered incoming sequence, of a outgoing sequence.
+ */
void addOffer(String msgID, String offerID);
+ /**
+ * Gets the offered incoming sequence, of outgoing sequence.
+ */
public String getOffer(String msgID);
+ /**
+ * clears the storage.
+ */
void clear();
}
\ No newline at end of file
1.13 +1 -164 ws-fx/sandesha/src/org/apache/sandesha/storage/dao/SandeshaDatabaseDAO.java
Index: SandeshaDatabaseDAO.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/storage/dao/SandeshaDatabaseDAO.java,v
retrieving revision 1.12
retrieving revision 1.13
diff -u -r1.12 -r1.13
--- SandeshaDatabaseDAO.java 14 May 2005 06:52:31 -0000 1.12
+++ SandeshaDatabaseDAO.java 18 May 2005 23:11:25 -0000 1.13
@@ -34,9 +34,6 @@
this.endPoint= endPoint;
}
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getAcksTo(java.lang.String)
- */
public String getAcksTo(String seqId) {
// TODO Auto-generated method stub
return null;
@@ -54,16 +51,11 @@
return null; //To change body of implemented methods use File | Settings | File Templates.
}
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#setAcksTo(java.lang.String, java.lang.String)
- */
public void setAcksTo(String seqId, String acksTo) {
// TODO Auto-generated method stub
}
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getFirstCreateSequenceMsgId(java.lang.String)
- */
+
public String getFirstCreateSequenceMsgId(String createSeqId) {
// TODO Auto-generated method stub
return null;
@@ -74,9 +66,6 @@
// TODO Auto-generated method stub
}
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#setResponseReceived(org.apache.sandesha.RMMessageContext)
- */
public void setResponseReceived(RMMessageContext msg) {
// TODO Auto-generated method stub
}
@@ -97,9 +86,6 @@
return false; //To change body of implemented methods use File | Settings | File Templates.
}
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#markOutgoingMessageToDelete(java.lang.String, java.lang.Long)
- */
public void markOutgoingMessageToDelete(String seqId, Long msgNo) {
// TODO Auto-generated method stub
}
@@ -109,219 +95,108 @@
return false;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.server.ISandeshaDAO#addOutQueueMessage()
- */
public boolean addPriorityMessage(RMMessageContext msg) {
// TODO Auto-generated method stub
return false;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.server.ISandeshaDAO#getNextMessageToSend()
- */
public RMMessageContext getNextMessageToSend() {
// TODO Auto-generated method stub
return null;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#addMessageToSequence(java.lang.String,
- * java.lang.Long, org.apache.sandesha.RMMessageContext)
- */
public boolean addMessageToIncomingSequence(String sequenceId, Long msgNo,
RMMessageContext rmMessageContext) {
// TODO Auto-generated method stub
return false;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#isSequenceExists(java.lang.String)
- */
public boolean isIncomingSequenceExists(String sequenceId) {
// TODO Auto-generated method stub
return false;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getNextMsgContextToProcess(java.lang.String)
- */
public RMMessageContext getNextMsgContextToProcess(String sequenceId) {
// TODO Auto-generated method stub
return null;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#hasNewMessages()
- */
public boolean hasNewMessages() {
// TODO Auto-generated method stub
return false;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getRandomSeqIdToProcess()
- */
public String getRandomSeqIdToProcess() {
// TODO Auto-generated method stub
return null;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getAllReceivedMsgNumsOfSeq(java.lang.String)
- */
public Set getAllReceivedMsgNumsOfIncomingSeq(String sequenceId) {
// TODO Auto-generated method stub
return null;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#isMessageExists(java.lang.String,
- * java.lang.String)
- */
public boolean isIncomingMessageExists(String sequenceId, Long msgNo) {
// TODO Auto-generated method stub
return false;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#addMessageToResponseSequence(java.lang.String,
- * org.apache.sandesha.RMMessageContext)
- */
public boolean addMessageToOutgoingSequence(String sequenceId,
RMMessageContext rmMessageContext) {
// TODO Auto-generated method stub
return false;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#addResponseSequence(java.lang.String)
- */
public boolean addOutgoingSequence(String sequenceId) {
// TODO Auto-generated method stub
return false;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getAllReceivedMsgNumsOfResponseSeq(java.lang.String)
- */
public Set getAllReceivedMsgNumsOfOutgoingSeq(String sequenceId) {
// TODO Auto-generated method stub
return null;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getNextPriorityMessageContextToSend()
- */
public RMMessageContext getNextPriorityMessageContextToSend() {
// TODO Auto-generated method stub
return null;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getNextResponseMsgContextToSend()
- */
public RMMessageContext getNextOutgoingMsgContextToSend() {
// TODO Auto-generated method stub
return null;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#isResponseSequenceExists(java.lang.String)
- */
public boolean isOutgoingSequenceExists(String sequenceId) {
// TODO Auto-generated method stub
return false;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#setOutSequence(java.lang.String,
- * java.lang.String)
- */
public void setOutSequence(String sequenceId, String outSequenceId) {
// TODO Auto-generated method stub
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#setOutSequenceApproved(java.lang.String,
- * boolean)
- */
public void setOutSequenceApproved(String sequenceID, boolean approved) {
// TODO Auto-generated method stub
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getSequenceOfOutSequence(java.lang.String)
- */
public String getSequenceOfOutSequence(String outsequenceId) {
// TODO Auto-generated method stub
return null;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#moveResponseMessageToBin(java.lang.String,
- * java.lang.Long)
- */
public void moveOutgoingMessageToBin(String sequenceId, Long msgNo) {
// TODO Auto-generated method stub
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#removeCreateSequenceMsg(java.lang.String)
- */
public void removeCreateSequenceMsg(String messageId) {
// TODO Auto-generated method stub
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getNextOutgoingMessageNumber(java.lang.String)
- */
public long getNextOutgoingMessageNumber(String sequenceId) {
// TODO Auto-generated method stub
return 0;
@@ -343,94 +218,56 @@
return null;
}
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#compareAcksWithSequence(java.lang.String)
- */
public boolean compareAcksWithSequence(String sequenceId) {
// TODO Auto-generated method stub
return false;
}
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#addLowPriorityMessage(org.apache.sandesha.RMMessageContext)
- */
public void addLowPriorityMessage(RMMessageContext msg) {
// TODO Auto-generated method stub
}
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getNextLowPriorityMessageContextToSend()
- */
public RMMessageContext getNextLowPriorityMessageContextToSend() {
// TODO Auto-generated method stub
return null;
}
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#addSendMsgNo(java.lang.String, long)
- */
public void addSendMsgNo(String seqId, long msgNo) {
// TODO Auto-generated method stub
}
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getLastIncomingMsgNo(java.lang.String)
- */
public long getLastIncomingMsgNo(String seqId) {
// TODO Auto-generated method stub
return 0;
}
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getLastOutgoingMsgNo(java.lang.String)
- */
public long getLastOutgoingMsgNo(String seqId) {
// TODO Auto-generated method stub
return 0;
}
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#hasLastIncomingMsgReceived(java.lang.String)
- */
public boolean hasLastIncomingMsgReceived(String seqId) {
// TODO Auto-generated method stub
return false;
}
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#hasLastOutgoingMsgReceived(java.lang.String)
- */
public boolean hasLastOutgoingMsgReceived(String seqId) {
// TODO Auto-generated method stub
return false;
}
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#isSentMsg(java.lang.String, long)
- */
public boolean isSentMsg(String seqId, long msgNo) {
// TODO Auto-generated method stub
return false;
}
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getKeyFromIncomingSequenceId(java.lang.String)
- */
public String getKeyFromIncomingSequenceId(String seqID) {
// TODO Auto-generated method stub
return null;
}
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getKeyFromOutgoingSequenceId(java.lang.String)
- */
public String getKeyFromOutgoingSequenceId(String seqID) {
// TODO Auto-generated method stub
return null;
1.14 +3 -102 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.13
retrieving revision 1.14
diff -u -r1.13 -r1.14
--- SandeshaQueueDAO.java 14 May 2005 06:52:31 -0000 1.13
+++ SandeshaQueueDAO.java 18 May 2005 23:11:25 -0000 1.14
@@ -79,12 +79,6 @@
return msg;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#addMessageToSequence(java.lang.String,
- * java.lang.Long, org.apache.sandesha.RMMessageContext)
- */
public boolean addMessageToIncomingSequence(String sequenceId, Long msgNo,
RMMessageContext rmMessageContext) {
boolean result = false;
@@ -100,22 +94,12 @@
return result;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#isSequenceExists(java.lang.String)
- */
public boolean isIncomingSequenceExists(String sequenceId) {
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
boolean exists = sq.isIncomingSequenceExists(sequenceId);
return exists;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getNextMsgContextToProcess(java.lang.String)
- */
public RMMessageContext getNextMsgContextToProcess(String sequenceId) {
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
RMMessageContext msg = null;
@@ -128,21 +112,11 @@
return msg;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#hasNewMessages()
- */
public boolean hasNewMessages() {
// TODO Auto-generated method stub
return false;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getRandomSeqIdToProcess()
- */
public String getRandomSeqIdToProcess() {
// TODO Auto-generated method stub
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
@@ -158,33 +132,16 @@
return id;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getAllReceivedMsgNumsOfSeq(java.lang.String)
- */
public Set getAllReceivedMsgNumsOfIncomingSeq(String sequenceId) {
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
return sq.getAllReceivedMsgNumsOfIncomingSeq(sequenceId);
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#isMessageExists(java.lang.String,
- * java.lang.String)
- */
public boolean isIncomingMessageExists(String sequenceId, Long msgNo) {
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
return sq.isIncomingMessageExists(sequenceId, msgNo);
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#addMessageToResponseSequence(java.lang.String,
- * org.apache.sandesha.RMMessageContext)
- */
public boolean addMessageToOutgoingSequence(String sequenceId,
RMMessageContext rmMessageContext) {
boolean result = false;
@@ -199,11 +156,6 @@
return result;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#addResponseSequence(java.lang.String)
- */
public boolean addOutgoingSequence(String sequenceId) {
boolean result = false;
try {
@@ -216,32 +168,17 @@
return result;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#isResponseSequenceExists(java.lang.String)
- */
public boolean isOutgoingSequenceExists(String sequenceId) {
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
boolean exists = sq.isOutgoingSequenceExists(sequenceId);
return exists;
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getAllReceivedMsgNumsOfResponseSeq(java.lang.String)
- */
public Set getAllReceivedMsgNumsOfOutgoingSeq(String sequenceId) {
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
return sq.getAllReceivedMsgNumsOfOutgoingSeq(sequenceId);
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getNextResponseMsgContextToSend()
- */
public RMMessageContext getNextOutgoingMsgContextToSend() {
RMMessageContext msg = null;
try {
@@ -264,45 +201,23 @@
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getSequenceOfOutSequence(java.lang.String)
- */
public String getSequenceOfOutSequence(String outsequenceId) {
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
return sq.getSequenceOfOutSequence(outsequenceId);
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#moveResponseMessageToBin(java.lang.String,
- * java.lang.Long)
- */
public void moveOutgoingMessageToBin(String sequenceId, Long msgNo) {
// TODO Auto-generated method stub
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
sq.moveOutgoingMsgToBin(sequenceId, msgNo);
}
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#removeCreateSequenceMsg(java.lang.String)
- */
public void removeCreateSequenceMsg(String messageId) {
// TODO Auto-generated method stub
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
sq.movePriorityMsgToBin(messageId);
}
-
- /*
- * (non-Javadoc)
- *
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getNextOutgoingMessageNumber(java.lang.String)
- */
public long getNextOutgoingMessageNumber(String sequenceId) {
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
return sq.getNextOutgoingMessageNumber(sequenceId);
@@ -330,18 +245,15 @@
}
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#markOutgoingMessageToDelete(java.lang.String, java.lang.Long)
+ /*
+ *
+ *
*/
public void markOutgoingMessageToDelete(String seqId, Long msgNo) {
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
sq.markOutgoingMessageToDelete(seqId, msgNo);
}
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#isAckComplete(java.lang.String)
- */
public boolean compareAcksWithSequence(String sequenceId) {
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
Vector acks = sq.getAllAckedMsgNumbers(sequenceId);
@@ -365,9 +277,6 @@
sq.setResponseReceived(msg);
}
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#addLowPriorityMessage(org.apache.sandesha.RMMessageContext)
- */
public void addLowPriorityMessage(RMMessageContext msg) {
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
try {
@@ -378,10 +287,6 @@
}
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getNextLowPriorityMessageContextToSend()
- */
public RMMessageContext getNextLowPriorityMessageContextToSend() {
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
try {
@@ -438,10 +343,6 @@
return sq.isRequestedSeqPresent(seqId);
}
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.storage.dao.ISandeshaDAO#getKeyFromIncomingSequenceId(java.lang.String)
- */
public String getKeyFromIncomingSequenceId(String seqID) {
SandeshaQueue sq = SandeshaQueue.getInstance(this.endPoint);
return sq.getKeyFromIncomingSequenceId(seqID);