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/13 13:27:09 UTC
cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server/dao IServerDAO.java ServerDAOFactory.java ServerDatabaseDAO.java ServerQueueDAO.java
jaliya 2004/09/13 04:27:09
Modified: sandesha/src/org/apache/sandesha/server/dao IServerDAO.java
ServerDAOFactory.java ServerDatabaseDAO.java
ServerQueueDAO.java
Log:
Formatted code
Revision Changes Path
1.4 +38 -22 ws-fx/sandesha/src/org/apache/sandesha/server/dao/IServerDAO.java
Index: IServerDAO.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/dao/IServerDAO.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- IServerDAO.java 6 Sep 2004 08:20:03 -0000 1.3
+++ IServerDAO.java 13 Sep 2004 11:27:09 -0000 1.4
@@ -16,7 +16,6 @@
*/
package org.apache.sandesha.server.dao;
-import java.util.Iterator;
import java.util.Set;
import org.apache.sandesha.RMMessageContext;
@@ -28,30 +27,47 @@
public interface IServerDAO {
boolean addSequence(String sequenceId);
- boolean addResponseSequence(String sequenceId);
+
+ boolean addResponseSequence(String sequenceId);
+
boolean addPriorityMessage(RMMessageContext message);
+
RMMessageContext getNextPriorityMessageContextToSend();
- boolean addMessageToSequence(String sequenceId,Long msgNo,RMMessageContext rmMessageContext);
- boolean addMessageToResponseSequence(String sequenceId,RMMessageContext rmMessageContext);
+
+ boolean addMessageToSequence(String sequenceId, Long msgNo,
+ RMMessageContext rmMessageContext);
+
+ boolean addMessageToResponseSequence(String sequenceId,
+ RMMessageContext rmMessageContext);
+
boolean isSequenceExists(String sequenceId);
- boolean isResponseSequenceExists(String sequenceId);
- boolean isMessageExists(String sequenceId,Long msgNo);
+
+ boolean isResponseSequenceExists(String sequenceId);
+
+ boolean isMessageExists(String sequenceId, Long msgNo);
+
RMMessageContext getNextMsgContextToProcess(String sequenceId);
-
- //RMMessageContext getNextResponseMsgContextToSend(String sequenceId);
- //String getRandomResponseSeqIdToSend();
- RMMessageContext getNextResponseMsgContextToSend(); //Used this instead of above 2.
-
- String getRandomSeqIdToProcess();
-
- Set getAllReceivedMsgNumsOfSeq(String sequenceId);
- Set getAllReceivedMsgNumsOfResponseSeq(String sequenceId);
- // boolean hasNewMessages();
-
- void setOutSequence(String sequenceId,String outSequenceId);
- void setOutSequenceApproved(String sequenceID,boolean approved);
- String getSequenceOfOutSequence(String outsequenceId);
- void moveResponseMessageToBin(String sequenceId,Long msgNo);
- void removeCreateSequenceMsg(String messageId);
+ //RMMessageContext getNextResponseMsgContextToSend(String sequenceId);
+ //String getRandomResponseSeqIdToSend();
+ RMMessageContext getNextResponseMsgContextToSend(); //Used this instead of
+ // above 2.
+
+ String getRandomSeqIdToProcess();
+
+ Set getAllReceivedMsgNumsOfSeq(String sequenceId);
+
+ Set getAllReceivedMsgNumsOfResponseSeq(String sequenceId);
+
+ // boolean hasNewMessages();
+
+ void setOutSequence(String sequenceId, String outSequenceId);
+
+ void setOutSequenceApproved(String sequenceID, boolean approved);
+
+ String getSequenceOfOutSequence(String outsequenceId);
+
+ void moveResponseMessageToBin(String sequenceId, Long msgNo);
+
+ void removeCreateSequenceMsg(String messageId);
}
1.2 +11 -11 ws-fx/sandesha/src/org/apache/sandesha/server/dao/ServerDAOFactory.java
Index: ServerDAOFactory.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/dao/ServerDAOFactory.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- ServerDAOFactory.java 16 Aug 2004 12:18:14 -0000 1.1
+++ ServerDAOFactory.java 13 Sep 2004 11:27:09 -0000 1.2
@@ -24,16 +24,16 @@
*/
public class ServerDAOFactory {
-
- public static IServerDAO getStorageAccessor(int accessor){
-
- if(accessor==Constants.SERVER_QUEUE_ACCESSOR)
- return new ServerQueueDAO();
- else if (accessor==Constants.SERVER_DATABASE_ACCESSOR)
- return new ServerDatabaseDAO();
- else
- return null;
-
+
+ public static IServerDAO getStorageAccessor(int accessor) {
+
+ if (accessor == Constants.SERVER_QUEUE_ACCESSOR)
+ return new ServerQueueDAO();
+ else if (accessor == Constants.SERVER_DATABASE_ACCESSOR)
+ return new ServerDatabaseDAO();
+ else
+ return null;
+
}
-}
+}
\ No newline at end of file
1.4 +211 -177 ws-fx/sandesha/src/org/apache/sandesha/server/dao/ServerDatabaseDAO.java
Index: ServerDatabaseDAO.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/dao/ServerDatabaseDAO.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- ServerDatabaseDAO.java 6 Sep 2004 08:22:24 -0000 1.3
+++ ServerDatabaseDAO.java 13 Sep 2004 11:27:09 -0000 1.4
@@ -16,7 +16,6 @@
*/
package org.apache.sandesha.server.dao;
-import java.util.Iterator;
import java.util.Set;
import org.apache.sandesha.RMMessageContext;
@@ -28,182 +27,217 @@
public class ServerDatabaseDAO implements IServerDAO {
+ public boolean addSequence(String sequenceId) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.IServerDAO#addOutQueueMessage()
+ */
+ public boolean addPriorityMessage(RMMessageContext msg) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.IServerDAO#getNextMessageToSend()
+ */
+ public RMMessageContext getNextMessageToSend() {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#addMessageToSequence(java.lang.String,
+ * java.lang.Long, org.apache.sandesha.RMMessageContext)
+ */
+ public boolean addMessageToSequence(String sequenceId, Long msgNo,
+ RMMessageContext rmMessageContext) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#isSequenceExists(java.lang.String)
+ */
+ public boolean isSequenceExists(String sequenceId) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#getNextMsgContextToProcess(java.lang.String)
+ */
+ public RMMessageContext getNextMsgContextToProcess(String sequenceId) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#hasNewMessages()
+ */
+ public boolean hasNewMessages() {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#getRandomSeqIdToProcess()
+ */
+ public String getRandomSeqIdToProcess() {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#getAllReceivedMsgNumsOfSeq(java.lang.String)
+ */
+ public Set getAllReceivedMsgNumsOfSeq(String sequenceId) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#isMessageExists(java.lang.String,
+ * java.lang.String)
+ */
+ public boolean isMessageExists(String sequenceId, Long msgNo) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#addMessageToResponseSequence(java.lang.String,
+ * org.apache.sandesha.RMMessageContext)
+ */
+ public boolean addMessageToResponseSequence(String sequenceId,
+ RMMessageContext rmMessageContext) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#addResponseSequence(java.lang.String)
+ */
+ public boolean addResponseSequence(String sequenceId) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#getAllReceivedMsgNumsOfResponseSeq(java.lang.String)
+ */
+ public Set getAllReceivedMsgNumsOfResponseSeq(String sequenceId) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#getNextPriorityMessageContextToSend()
+ */
+ public RMMessageContext getNextPriorityMessageContextToSend() {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#getNextResponseMsgContextToSend()
+ */
+ public RMMessageContext getNextResponseMsgContextToSend() {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#isResponseSequenceExists(java.lang.String)
+ */
+ public boolean isResponseSequenceExists(String sequenceId) {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#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.server.dao.IServerDAO#setOutSequenceApproved(java.lang.String,
+ * boolean)
+ */
+ public void setOutSequenceApproved(String sequenceID, boolean approved) {
+ // TODO Auto-generated method stub
+
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#getSequenceOfOutSequence(java.lang.String)
+ */
+ public String getSequenceOfOutSequence(String outsequenceId) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ /*
+ * (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
+
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#removeCreateSequenceMsg(java.lang.String)
+ */
+ public void removeCreateSequenceMsg(String messageId) {
+ // TODO Auto-generated method stub
-
- public boolean addSequence(String sequenceId) {
- // TODO Auto-generated method stub
- return false;
- }
-
-
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.IServerDAO#addOutQueueMessage()
- */
- public boolean addPriorityMessage(RMMessageContext msg) {
- // TODO Auto-generated method stub
- return false;
- }
-
-
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.IServerDAO#getNextMessageToSend()
- */
- public RMMessageContext getNextMessageToSend() {
- // TODO Auto-generated method stub
- return null;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#addMessageToSequence(java.lang.String, java.lang.Long, org.apache.sandesha.RMMessageContext)
- */
- public boolean addMessageToSequence(
- String sequenceId,
- Long msgNo,
- RMMessageContext rmMessageContext) {
- // TODO Auto-generated method stub
- return false;
- }
-
-
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#isSequenceExists(java.lang.String)
- */
- public boolean isSequenceExists(String sequenceId) {
- // TODO Auto-generated method stub
- return false;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#getNextMsgContextToProcess(java.lang.String)
- */
- public RMMessageContext getNextMsgContextToProcess(String sequenceId) {
- // TODO Auto-generated method stub
- return null;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#hasNewMessages()
- */
- public boolean hasNewMessages() {
- // TODO Auto-generated method stub
- return false;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#getRandomSeqIdToProcess()
- */
- public String getRandomSeqIdToProcess() {
- // TODO Auto-generated method stub
- return null;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#getAllReceivedMsgNumsOfSeq(java.lang.String)
- */
- public Set getAllReceivedMsgNumsOfSeq(String sequenceId) {
- // TODO Auto-generated method stub
- return null;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#isMessageExists(java.lang.String, java.lang.String)
- */
- public boolean isMessageExists(String sequenceId, Long msgNo) {
- // TODO Auto-generated method stub
- return false;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#addMessageToResponseSequence(java.lang.String, org.apache.sandesha.RMMessageContext)
- */
- public boolean addMessageToResponseSequence(
- String sequenceId,
- RMMessageContext rmMessageContext) {
- // TODO Auto-generated method stub
- return false;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#addResponseSequence(java.lang.String)
- */
- public boolean addResponseSequence(String sequenceId) {
- // TODO Auto-generated method stub
- return false;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#getAllReceivedMsgNumsOfResponseSeq(java.lang.String)
- */
- public Set getAllReceivedMsgNumsOfResponseSeq(String sequenceId) {
- // TODO Auto-generated method stub
- return null;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#getNextPriorityMessageContextToSend()
- */
- public RMMessageContext getNextPriorityMessageContextToSend() {
- // TODO Auto-generated method stub
- return null;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#getNextResponseMsgContextToSend()
- */
- public RMMessageContext getNextResponseMsgContextToSend() {
- // TODO Auto-generated method stub
- return null;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#isResponseSequenceExists(java.lang.String)
- */
- public boolean isResponseSequenceExists(String sequenceId) {
- // TODO Auto-generated method stub
- return false;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#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.server.dao.IServerDAO#setOutSequenceApproved(java.lang.String, boolean)
- */
- public void setOutSequenceApproved(String sequenceID, boolean approved) {
- // TODO Auto-generated method stub
-
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#getSequenceOfOutSequence(java.lang.String)
- */
- public String getSequenceOfOutSequence(String outsequenceId) {
- // TODO Auto-generated method stub
- return null;
- }
-
- /* (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
-
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#removeCreateSequenceMsg(java.lang.String)
- */
- public void removeCreateSequenceMsg(String messageId) {
- // TODO Auto-generated method stub
-
- }
+ }
}
1.4 +313 -310 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.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- ServerQueueDAO.java 6 Sep 2004 08:21:23 -0000 1.3
+++ ServerQueueDAO.java 13 Sep 2004 11:27:09 -0000 1.4
@@ -16,14 +16,10 @@
*/
package org.apache.sandesha.server.dao;
-import java.util.Iterator;
import java.util.Random;
import java.util.Set;
import java.util.Vector;
-import javax.sound.midi.Sequence;
-
-
import org.apache.axis.components.logger.LogFactory;
import org.apache.commons.logging.Log;
import org.apache.sandesha.RMMessageContext;
@@ -37,312 +33,319 @@
public class ServerQueueDAO implements IServerDAO {
- protected static Log log =
- LogFactory.getLog(ServerQueueDAO.class.getName());
-
- public boolean addSequence(String sequenceId) {
- boolean result = false;
- try{
- ServerQueue sq = ServerQueue.getInstance();
- sq.createNewSequence(sequenceId);
- result=true;
- }catch(QueueException e){
- log.error(e);
- }
-
- return result;
- }
-
-
-
- public boolean addPriorityMessage(RMMessageContext msg) {
- boolean result = false;
- try{
- ServerQueue sq = ServerQueue.getInstance();
- sq.addPriorityMessage(msg);
- }catch(QueueException e){
- log.error(e);
- }
-
- return result;
- }
-
-
-
- public RMMessageContext getNextPriorityMessageContextToSend() {
- RMMessageContext msg = null;
- try{
- ServerQueue sq = ServerQueue.getInstance();
- msg = sq.nextPriorityMessageToSend();
- }catch(QueueException e){
- log.error(e);
- e.printStackTrace();
- }
-
- return msg;
- }
-
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#addMessageToSequence(java.lang.String, java.lang.Long, org.apache.sandesha.RMMessageContext)
- */
- public boolean addMessageToSequence(
- String sequenceId,
- Long msgNo,
- RMMessageContext rmMessageContext) {
-
- boolean result = false;
- try{
- ServerQueue sq = ServerQueue.getInstance();
- sq.addMessageToSequence(sequenceId,msgNo,rmMessageContext);
- result = true;
- }catch(QueueException e){
- log.error(e);
- e.printStackTrace();
- }
- return result;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#isSequenceExists(java.lang.String)
- */
- public boolean isSequenceExists(String sequenceId) {
-
- ServerQueue sq = ServerQueue.getInstance();
- boolean exists = sq.isSequenceExists(sequenceId);
-
- return exists;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#getNextMsgContextToProcess(java.lang.String)
- */
- public RMMessageContext getNextMsgContextToProcess(String sequenceId) {
- ServerQueue sq = ServerQueue.getInstance();
-
- RMMessageContext msg = null;
- try{
- msg = sq.nextMessageToProcess(sequenceId);
- }catch(Exception e){
- log.error(e);
- e.printStackTrace();
- }
-
- return msg;
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#hasNewMessages()
- */
- public boolean hasNewMessages() {
- // TODO Auto-generated method stub
- return false;
- }
-
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#getRandomSeqIdToProcess()
- */
- public String getRandomSeqIdToProcess() {
- // TODO Auto-generated method stub
- ServerQueue sq = ServerQueue.getInstance();
- Vector ids = sq.nextAllSeqIdsToProcess();
-
- int size = ids.size();
-
- if(size<=0)
- return null;
-
- Random r = new Random();
- int number = r.nextInt(size);
- String id = (String) ids.get(number);
-
- sq.setSequenceLock(id,true); //Locks the sequence temporarily to tell that it is locked.
- return id;
- }
-
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#getAllReceivedMsgNumsOfSeq(java.lang.String)
- */
- public Set getAllReceivedMsgNumsOfSeq(String sequenceId) {
-
- ServerQueue sq = ServerQueue.getInstance();
- return sq.getAllReceivedMsgNumsOfSeq(sequenceId);
- }
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#isMessageExists(java.lang.String, java.lang.String)
- */
- public boolean isMessageExists(String sequenceId, Long msgNo) {
-
- ServerQueue sq = ServerQueue.getInstance();
- return sq.isMessageExists(sequenceId,msgNo);
- }
-
-
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#addMessageToResponseSequence(java.lang.String, org.apache.sandesha.RMMessageContext)
- */
- public boolean addMessageToResponseSequence(
- String sequenceId,
- RMMessageContext rmMessageContext) {
-
- boolean result = false;
- try{
- ServerQueue sq = ServerQueue.getInstance();
- sq.addMessageToResponseSequence(sequenceId,rmMessageContext);
- result = true;
- }catch(QueueException e){
- log.error(e);
- e.printStackTrace();
- }
- return result;
- }
-
-
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#addResponseSequence(java.lang.String)
- */
- public boolean addResponseSequence(String sequenceId) {
- boolean result = false;
- try{
- ServerQueue sq = ServerQueue.getInstance();
- sq.createNewResponseSequence(sequenceId);
- result=true;
- }catch(QueueException e){
- log.error(e);
- }
-
- return result;
- }
-
-
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#isResponseSequenceExists(java.lang.String)
- */
- public boolean isResponseSequenceExists(String sequenceId) {
-
- ServerQueue sq = ServerQueue.getInstance();
- boolean exists = sq.isResponseSequenceExists(sequenceId);
-
- return exists;
- }
-
-
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#getNextResponseMsgContextToProcess(java.lang.String)
- */
- /*public RMMessageContext getNextResponseMsgContextToSend(String sequenceId) {
-
- ServerQueue sq = ServerQueue.getInstance();
-
- RMMessageContext msg = null;
- try{
- msg = sq.nextResponseMessageToSend(sequenceId);
- }catch(Exception e){
- log.error(e);
- e.printStackTrace();
- }
-
- return msg;
- }*/
-
-
-
-
-
-
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#getAllReceivedMsgNumsOfResponseSeq(java.lang.String)
- */
- public Set getAllReceivedMsgNumsOfResponseSeq(String sequenceId) {
- ServerQueue sq = ServerQueue.getInstance();
- return sq.getAllReceivedMsgNumsOfResponseSeq(sequenceId);
- }
-
-
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#getRandomResponseSeqIdToSend()
- */
- /*public String getRandomResponseSeqIdToSend() {
- // TODO Auto-generated method stub
- ServerQueue sq = ServerQueue.getInstance();
- Vector ids = sq.nextAllResponseSeqIdsToSend();
-
- int size = ids.size();
-
- if(size<=0)
- return null;
-
- Random r = new Random();
- int number = r.nextInt(size);
- String id = (String) ids.get(number);
-
- sq.setSequenceLock(id,true); //Locks the sequence temporarily to tell that it is locked.
- return id;
- }*/
-
-
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#getNextResponseMsgContextToSend()
- */
- public RMMessageContext getNextResponseMsgContextToSend() {
- RMMessageContext msg = null;
- try{
- ServerQueue sq = ServerQueue.getInstance();
- msg = sq.nextResponseMessageToSend();
- }catch(QueueException e){
- log.error(e);
- }
- return msg;
- }
-
- public void setOutSequence(String seqId,String outSeqId){
- ServerQueue sq = ServerQueue.getInstance();
- sq.setOutSequence(seqId,outSeqId);
-
- }
- public void setOutSequenceApproved(String seqId,boolean approved){
- ServerQueue sq = ServerQueue.getInstance();
- sq.setOutSequenceApproved(seqId,approved);
-
- }
-
-
- /* (non-Javadoc)
- * @see org.apache.sandesha.server.dao.IServerDAO#getSequenceOfOutSequence(java.lang.String)
- */
- public String getSequenceOfOutSequence(String outsequenceId) {
- ServerQueue sq = ServerQueue.getInstance();
- 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);
+ protected static Log log = LogFactory
+ .getLog(ServerQueueDAO.class.getName());
+
+ public boolean addSequence(String sequenceId) {
+ boolean result = false;
+ try {
+ ServerQueue sq = ServerQueue.getInstance();
+ sq.createNewSequence(sequenceId);
+ result = true;
+ } catch (QueueException e) {
+ log.error(e);
+ }
+
+ return result;
+ }
+
+ public boolean addPriorityMessage(RMMessageContext msg) {
+ boolean result = false;
+ try {
+ ServerQueue sq = ServerQueue.getInstance();
+ sq.addPriorityMessage(msg);
+ } catch (QueueException e) {
+ log.error(e);
+ }
+
+ return result;
+ }
+
+ public RMMessageContext getNextPriorityMessageContextToSend() {
+ RMMessageContext msg = null;
+ try {
+ ServerQueue sq = ServerQueue.getInstance();
+ msg = sq.nextPriorityMessageToSend();
+ } catch (QueueException e) {
+ log.error(e);
+ e.printStackTrace();
+ }
+
+ return msg;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#addMessageToSequence(java.lang.String,
+ * java.lang.Long, org.apache.sandesha.RMMessageContext)
+ */
+ public boolean addMessageToSequence(String sequenceId, Long msgNo,
+ RMMessageContext rmMessageContext) {
+
+ boolean result = false;
+ try {
+ ServerQueue sq = ServerQueue.getInstance();
+ sq.addMessageToSequence(sequenceId, msgNo, rmMessageContext);
+ result = true;
+ } catch (QueueException e) {
+ log.error(e);
+ e.printStackTrace();
+ }
+ return result;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#isSequenceExists(java.lang.String)
+ */
+ public boolean isSequenceExists(String sequenceId) {
+
+ ServerQueue sq = ServerQueue.getInstance();
+ boolean exists = sq.isSequenceExists(sequenceId);
+
+ return exists;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#getNextMsgContextToProcess(java.lang.String)
+ */
+ public RMMessageContext getNextMsgContextToProcess(String sequenceId) {
+ ServerQueue sq = ServerQueue.getInstance();
+
+ RMMessageContext msg = null;
+ try {
+ msg = sq.nextMessageToProcess(sequenceId);
+ } catch (Exception e) {
+ log.error(e);
+ e.printStackTrace();
+ }
+
+ return msg;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#hasNewMessages()
+ */
+ public boolean hasNewMessages() {
+ // TODO Auto-generated method stub
+ return false;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#getRandomSeqIdToProcess()
+ */
+ public String getRandomSeqIdToProcess() {
+ // TODO Auto-generated method stub
+ ServerQueue sq = ServerQueue.getInstance();
+ Vector ids = sq.nextAllSeqIdsToProcess();
+
+ int size = ids.size();
+
+ if (size <= 0)
+ return null;
+
+ Random r = new Random();
+ int number = r.nextInt(size);
+ String id = (String) ids.get(number);
+
+ sq.setSequenceLock(id, true); //Locks the sequence temporarily to tell
+ // that it is locked.
+ return id;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#getAllReceivedMsgNumsOfSeq(java.lang.String)
+ */
+ public Set getAllReceivedMsgNumsOfSeq(String sequenceId) {
+
+ ServerQueue sq = ServerQueue.getInstance();
+ return sq.getAllReceivedMsgNumsOfSeq(sequenceId);
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#isMessageExists(java.lang.String,
+ * java.lang.String)
+ */
+ public boolean isMessageExists(String sequenceId, Long msgNo) {
+
+ ServerQueue sq = ServerQueue.getInstance();
+ return sq.isMessageExists(sequenceId, msgNo);
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#addMessageToResponseSequence(java.lang.String,
+ * org.apache.sandesha.RMMessageContext)
+ */
+ public boolean addMessageToResponseSequence(String sequenceId,
+ RMMessageContext rmMessageContext) {
+
+ boolean result = false;
+ try {
+ ServerQueue sq = ServerQueue.getInstance();
+ sq.addMessageToResponseSequence(sequenceId, rmMessageContext);
+ result = true;
+ } catch (QueueException e) {
+ log.error(e);
+ e.printStackTrace();
+ }
+ return result;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#addResponseSequence(java.lang.String)
+ */
+ public boolean addResponseSequence(String sequenceId) {
+ boolean result = false;
+ try {
+ ServerQueue sq = ServerQueue.getInstance();
+ sq.createNewResponseSequence(sequenceId);
+ result = true;
+ } catch (QueueException e) {
+ log.error(e);
+ }
+
+ return result;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#isResponseSequenceExists(java.lang.String)
+ */
+ public boolean isResponseSequenceExists(String sequenceId) {
+
+ ServerQueue sq = ServerQueue.getInstance();
+ boolean exists = sq.isResponseSequenceExists(sequenceId);
+
+ return exists;
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#getNextResponseMsgContextToProcess(java.lang.String)
+ */
+ /*
+ * public RMMessageContext getNextResponseMsgContextToSend(String
+ * sequenceId) {
+ *
+ * ServerQueue sq = ServerQueue.getInstance();
+ *
+ * RMMessageContext msg = null; try{ msg =
+ * sq.nextResponseMessageToSend(sequenceId); }catch(Exception e){
+ * log.error(e); e.printStackTrace(); }
+ *
+ * return msg; }
+ */
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#getAllReceivedMsgNumsOfResponseSeq(java.lang.String)
+ */
+ public Set getAllReceivedMsgNumsOfResponseSeq(String sequenceId) {
+ ServerQueue sq = ServerQueue.getInstance();
+ return sq.getAllReceivedMsgNumsOfResponseSeq(sequenceId);
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#getRandomResponseSeqIdToSend()
+ */
+ /*
+ * public String getRandomResponseSeqIdToSend() { // TODO Auto-generated
+ * method stub ServerQueue sq = ServerQueue.getInstance(); Vector ids =
+ * sq.nextAllResponseSeqIdsToSend();
+ *
+ * int size = ids.size();
+ *
+ * if(size <=0) return null;
+ *
+ * Random r = new Random(); int number = r.nextInt(size); String id =
+ * (String) ids.get(number);
+ *
+ * sq.setSequenceLock(id,true); //Locks the sequence temporarily to tell
+ * that it is locked. return id; }
+ */
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#getNextResponseMsgContextToSend()
+ */
+ public RMMessageContext getNextResponseMsgContextToSend() {
+ RMMessageContext msg = null;
+ try {
+ ServerQueue sq = ServerQueue.getInstance();
+ msg = sq.nextResponseMessageToSend();
+ } catch (QueueException e) {
+ log.error(e);
+ }
+ return msg;
+ }
+
+ public void setOutSequence(String seqId, String outSeqId) {
+ ServerQueue sq = ServerQueue.getInstance();
+ sq.setOutSequence(seqId, outSeqId);
+
+ }
+
+ public void setOutSequenceApproved(String seqId, boolean approved) {
+ ServerQueue sq = ServerQueue.getInstance();
+ sq.setOutSequenceApproved(seqId, approved);
+
+ }
+
+ /*
+ * (non-Javadoc)
+ *
+ * @see org.apache.sandesha.server.dao.IServerDAO#getSequenceOfOutSequence(java.lang.String)
+ */
+ public String getSequenceOfOutSequence(String outsequenceId) {
+ ServerQueue sq = ServerQueue.getInstance();
+ 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);
- }
+ }
}