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/20 14:16:18 UTC
cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server/dao ServerDatabaseDAO.java ServerQueueDAO.java
jaliya 2004/09/20 05:16:18
Modified: sandesha/src/org/apache/sandesha/server/dao
ServerDatabaseDAO.java ServerQueueDAO.java
Log:
Changes were done to support for the client side implementation
Revision Changes Path
1.5 +19 -11 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.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- ServerDatabaseDAO.java 13 Sep 2004 11:27:09 -0000 1.4
+++ ServerDatabaseDAO.java 20 Sep 2004 12:16:18 -0000 1.5
@@ -27,7 +27,7 @@
public class ServerDatabaseDAO implements IServerDAO {
- public boolean addSequence(String sequenceId) {
+ public boolean addIncomingSequence(String sequenceId) {
// TODO Auto-generated method stub
return false;
}
@@ -58,7 +58,7 @@
* @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,
+ public boolean addMessageToIncomingSequence(String sequenceId, Long msgNo,
RMMessageContext rmMessageContext) {
// TODO Auto-generated method stub
return false;
@@ -69,7 +69,7 @@
*
* @see org.apache.sandesha.server.dao.IServerDAO#isSequenceExists(java.lang.String)
*/
- public boolean isSequenceExists(String sequenceId) {
+ public boolean isIncomingSequenceExists(String sequenceId) {
// TODO Auto-generated method stub
return false;
}
@@ -109,7 +109,7 @@
*
* @see org.apache.sandesha.server.dao.IServerDAO#getAllReceivedMsgNumsOfSeq(java.lang.String)
*/
- public Set getAllReceivedMsgNumsOfSeq(String sequenceId) {
+ public Set getAllReceivedMsgNumsOfIncomingSeq(String sequenceId) {
// TODO Auto-generated method stub
return null;
}
@@ -120,7 +120,7 @@
* @see org.apache.sandesha.server.dao.IServerDAO#isMessageExists(java.lang.String,
* java.lang.String)
*/
- public boolean isMessageExists(String sequenceId, Long msgNo) {
+ public boolean isIncomingMessageExists(String sequenceId, Long msgNo) {
// TODO Auto-generated method stub
return false;
}
@@ -131,7 +131,7 @@
* @see org.apache.sandesha.server.dao.IServerDAO#addMessageToResponseSequence(java.lang.String,
* org.apache.sandesha.RMMessageContext)
*/
- public boolean addMessageToResponseSequence(String sequenceId,
+ public boolean addMessageToOutgoingSequence(String sequenceId,
RMMessageContext rmMessageContext) {
// TODO Auto-generated method stub
return false;
@@ -142,7 +142,7 @@
*
* @see org.apache.sandesha.server.dao.IServerDAO#addResponseSequence(java.lang.String)
*/
- public boolean addResponseSequence(String sequenceId) {
+ public boolean addOutgoingSequence(String sequenceId) {
// TODO Auto-generated method stub
return false;
}
@@ -152,7 +152,7 @@
*
* @see org.apache.sandesha.server.dao.IServerDAO#getAllReceivedMsgNumsOfResponseSeq(java.lang.String)
*/
- public Set getAllReceivedMsgNumsOfResponseSeq(String sequenceId) {
+ public Set getAllReceivedMsgNumsOfOutgoingSeq(String sequenceId) {
// TODO Auto-generated method stub
return null;
}
@@ -172,7 +172,7 @@
*
* @see org.apache.sandesha.server.dao.IServerDAO#getNextResponseMsgContextToSend()
*/
- public RMMessageContext getNextResponseMsgContextToSend() {
+ public RMMessageContext getNextOutgoingMsgContextToSend() {
// TODO Auto-generated method stub
return null;
}
@@ -182,7 +182,7 @@
*
* @see org.apache.sandesha.server.dao.IServerDAO#isResponseSequenceExists(java.lang.String)
*/
- public boolean isResponseSequenceExists(String sequenceId) {
+ public boolean isOutgoingSequenceExists(String sequenceId) {
// TODO Auto-generated method stub
return false;
}
@@ -225,7 +225,7 @@
* @see org.apache.sandesha.server.dao.IServerDAO#moveResponseMessageToBin(java.lang.String,
* java.lang.Long)
*/
- public void moveResponseMessageToBin(String sequenceId, Long msgNo) {
+ public void moveOutgoingMessageToBin(String sequenceId, Long msgNo) {
// TODO Auto-generated method stub
}
@@ -239,5 +239,13 @@
// TODO Auto-generated method stub
}
+
+ /* (non-Javadoc)
+ * @see org.apache.sandesha.server.dao.IServerDAO#getNextOutgoingMessageNumber(java.lang.String)
+ */
+ public long getNextOutgoingMessageNumber(String sequenceId) {
+ // TODO Auto-generated method stub
+ return 0;
+ }
}
1.5 +31 -23 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.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- ServerQueueDAO.java 13 Sep 2004 11:27:09 -0000 1.4
+++ ServerQueueDAO.java 20 Sep 2004 12:16:18 -0000 1.5
@@ -36,11 +36,11 @@
protected static Log log = LogFactory
.getLog(ServerQueueDAO.class.getName());
- public boolean addSequence(String sequenceId) {
+ public boolean addIncomingSequence(String sequenceId) {
boolean result = false;
try {
ServerQueue sq = ServerQueue.getInstance();
- sq.createNewSequence(sequenceId);
+ sq.createNewIncomingSequence(sequenceId);
result = true;
} catch (QueueException e) {
log.error(e);
@@ -80,13 +80,13 @@
* @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,
+ public boolean addMessageToIncomingSequence(String sequenceId, Long msgNo,
RMMessageContext rmMessageContext) {
boolean result = false;
try {
ServerQueue sq = ServerQueue.getInstance();
- sq.addMessageToSequence(sequenceId, msgNo, rmMessageContext);
+ sq.addMessageToIncomingSequence(sequenceId, msgNo, rmMessageContext);
result = true;
} catch (QueueException e) {
log.error(e);
@@ -100,10 +100,10 @@
*
* @see org.apache.sandesha.server.dao.IServerDAO#isSequenceExists(java.lang.String)
*/
- public boolean isSequenceExists(String sequenceId) {
+ public boolean isIncomingSequenceExists(String sequenceId) {
ServerQueue sq = ServerQueue.getInstance();
- boolean exists = sq.isSequenceExists(sequenceId);
+ boolean exists = sq.isIncomingSequenceExists(sequenceId);
return exists;
}
@@ -118,7 +118,7 @@
RMMessageContext msg = null;
try {
- msg = sq.nextMessageToProcess(sequenceId);
+ msg = sq.nextIncomingMessageToProcess(sequenceId);
} catch (Exception e) {
log.error(e);
e.printStackTrace();
@@ -166,10 +166,10 @@
*
* @see org.apache.sandesha.server.dao.IServerDAO#getAllReceivedMsgNumsOfSeq(java.lang.String)
*/
- public Set getAllReceivedMsgNumsOfSeq(String sequenceId) {
+ public Set getAllReceivedMsgNumsOfIncomingSeq(String sequenceId) {
ServerQueue sq = ServerQueue.getInstance();
- return sq.getAllReceivedMsgNumsOfSeq(sequenceId);
+ return sq.getAllReceivedMsgNumsOfIncomingSeq(sequenceId);
}
/*
@@ -178,10 +178,10 @@
* @see org.apache.sandesha.server.dao.IServerDAO#isMessageExists(java.lang.String,
* java.lang.String)
*/
- public boolean isMessageExists(String sequenceId, Long msgNo) {
+ public boolean isIncomingMessageExists(String sequenceId, Long msgNo) {
ServerQueue sq = ServerQueue.getInstance();
- return sq.isMessageExists(sequenceId, msgNo);
+ return sq.isIncomingMessageExists(sequenceId, msgNo);
}
/*
@@ -190,13 +190,13 @@
* @see org.apache.sandesha.server.dao.IServerDAO#addMessageToResponseSequence(java.lang.String,
* org.apache.sandesha.RMMessageContext)
*/
- public boolean addMessageToResponseSequence(String sequenceId,
+ public boolean addMessageToOutgoingSequence(String sequenceId,
RMMessageContext rmMessageContext) {
boolean result = false;
try {
ServerQueue sq = ServerQueue.getInstance();
- sq.addMessageToResponseSequence(sequenceId, rmMessageContext);
+ sq.addMessageToOutgoingSequence(sequenceId, rmMessageContext);
result = true;
} catch (QueueException e) {
log.error(e);
@@ -210,11 +210,11 @@
*
* @see org.apache.sandesha.server.dao.IServerDAO#addResponseSequence(java.lang.String)
*/
- public boolean addResponseSequence(String sequenceId) {
+ public boolean addOutgoingSequence(String sequenceId) {
boolean result = false;
try {
ServerQueue sq = ServerQueue.getInstance();
- sq.createNewResponseSequence(sequenceId);
+ sq.createNewOutgoingSequence(sequenceId);
result = true;
} catch (QueueException e) {
log.error(e);
@@ -228,10 +228,10 @@
*
* @see org.apache.sandesha.server.dao.IServerDAO#isResponseSequenceExists(java.lang.String)
*/
- public boolean isResponseSequenceExists(String sequenceId) {
+ public boolean isOutgoingSequenceExists(String sequenceId) {
ServerQueue sq = ServerQueue.getInstance();
- boolean exists = sq.isResponseSequenceExists(sequenceId);
+ boolean exists = sq.isOutgoingSequenceExists(sequenceId);
return exists;
}
@@ -259,9 +259,9 @@
*
* @see org.apache.sandesha.server.dao.IServerDAO#getAllReceivedMsgNumsOfResponseSeq(java.lang.String)
*/
- public Set getAllReceivedMsgNumsOfResponseSeq(String sequenceId) {
+ public Set getAllReceivedMsgNumsOfOutgoingSeq(String sequenceId) {
ServerQueue sq = ServerQueue.getInstance();
- return sq.getAllReceivedMsgNumsOfResponseSeq(sequenceId);
+ return sq.getAllReceivedMsgNumsOfOutgoingSeq(sequenceId);
}
/*
@@ -290,11 +290,11 @@
*
* @see org.apache.sandesha.server.dao.IServerDAO#getNextResponseMsgContextToSend()
*/
- public RMMessageContext getNextResponseMsgContextToSend() {
+ public RMMessageContext getNextOutgoingMsgContextToSend() {
RMMessageContext msg = null;
try {
ServerQueue sq = ServerQueue.getInstance();
- msg = sq.nextResponseMessageToSend();
+ msg = sq.nextOutgoingMessageToSend();
} catch (QueueException e) {
log.error(e);
}
@@ -329,10 +329,10 @@
* @see org.apache.sandesha.server.dao.IServerDAO#moveResponseMessageToBin(java.lang.String,
* java.lang.Long)
*/
- public void moveResponseMessageToBin(String sequenceId, Long msgNo) {
+ public void moveOutgoingMessageToBin(String sequenceId, Long msgNo) {
// TODO Auto-generated method stub
ServerQueue sq = ServerQueue.getInstance();
- sq.moveResponseMsgToBin(sequenceId, msgNo);
+ sq.moveOutgoingMsgToBin(sequenceId, msgNo);
}
@@ -347,5 +347,13 @@
sq.movePriorityMsgToBin(messageId);
}
+
+ /* (non-Javadoc)
+ * @see org.apache.sandesha.server.dao.IServerDAO#getNextOutgoingMessageNumber(java.lang.String)
+ */
+ public long getNextOutgoingMessageNumber(String sequenceId) {
+ ServerQueue sq = ServerQueue.getInstance();
+ return sq.getNextOutgoingMessageNumber(sequenceId);
+ }
}