Re: cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server/dao IServerDAO.java ServerDatabaseDAO.java ServerQueueDAO.java

Hi Jaliya- please make sure you put a log when you commit ... as
detailed as possible! That's the only way for others to follow
your work and contribute to it.

Sanjiva.

----- Original Message ----- 
From: <jaliya-1oDqGaOF3Lkdnm+yROfE0A@xxxxxxxxxxxxxxxx>
To: <ws-fx-cvs-1oDqGaOF3Lkdnm+yROfE0A@xxxxxxxxxxxxxxxx>
Sent: Friday, August 20, 2004 7:14 PM
Subject: cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server/dao
IServerDAO.java ServerDatabaseDAO.java ServerQueueDAO.java


> jaliya      2004/08/20 06:14:35
>
>   Modified:    sandesha/src/org/apache/sandesha/server/dao IServerDAO.java
>                         ServerDatabaseDAO.java ServerQueueDAO.java
>   Log:
>
>
>   Revision  Changes    Path
>   1.2       +16 -2
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.1
>   retrieving revision 1.2
>   diff -u -r1.1 -r1.2
>   --- IServerDAO.java 16 Aug 2004 12:15:16 -0000 1.1
>   +++ IServerDAO.java 20 Aug 2004 13:14:34 -0000 1.2
>   @@ -28,13 +28,27 @@
>
>    public interface IServerDAO {
>        boolean addSequence(String sequenceId);
>   -    boolean addOutQueueMessage(RMMessageContext message);
>   -    RMMessageContext getNextMessageToSend();
>   + 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 isSequenceExists(String sequenceId);
>   + 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);
>    }
>
>
>
>   1.2       +75 -1
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/ServerDatabaseDA
O.java,v
>   retrieving revision 1.1
>   retrieving revision 1.2
>   diff -u -r1.1 -r1.2
>   --- ServerDatabaseDAO.java 16 Aug 2004 12:16:59 -0000 1.1
>   +++ ServerDatabaseDAO.java 20 Aug 2004 13:14:35 -0000 1.2
>   @@ -40,7 +40,7 @@
>    /* (non-Javadoc)
>    * @see org.apache.sandesha.server.IServerDAO#addOutQueueMessage()
>    */
>   - public boolean addOutQueueMessage(RMMessageContext msg) {
>   + public boolean addPriorityMessage(RMMessageContext msg) {
>    // TODO Auto-generated method stub
>    return false;
>    }
>   @@ -114,6 +114,80 @@
>    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.Stri
ng)
>   + */
>   + 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#getNextPriorityMessageContextToSen
d()
>   + */
>   + 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.S
tring, 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;
>    }
>
>    }
>
>
>
>   1.2       +151 -4
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.j
ava,v
>   retrieving revision 1.1
>   retrieving revision 1.2
>   diff -u -r1.1 -r1.2
>   --- ServerQueueDAO.java 16 Aug 2004 12:15:57 -0000 1.1
>   +++ ServerQueueDAO.java 20 Aug 2004 13:14:35 -0000 1.2
>   @@ -21,6 +21,8 @@
>    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;
>   @@ -53,11 +55,11 @@
>
>
>
>   - public boolean addOutQueueMessage(RMMessageContext msg) {
>   + public boolean addPriorityMessage(RMMessageContext msg) {
>    boolean result = false;
>    try{
>    ServerQueue sq = ServerQueue.getInstance();
>   - sq.addMessageToOutQueue(msg);
>   + sq.addPriorityMessage(msg);
>    }catch(QueueException e){
>    log.error(e);
>    }
>   @@ -67,11 +69,11 @@
>
>
>
>   - public RMMessageContext getNextMessageToSend() {
>   + public RMMessageContext getNextPriorityMessageContextToSend() {
>    RMMessageContext msg = null;
>    try{
>    ServerQueue sq = ServerQueue.getInstance();
>   - msg = sq.nextOutQueueMessage();
>   + msg = sq.nextPriorityMessageToSend();
>    }catch(QueueException e){
>    log.error(e);
>    e.printStackTrace();
>   @@ -176,6 +178,151 @@
>
>    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.Stri
ng)
>   + */
>   + 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);
>    }
>
>    }
>
>
>
>