Please take our Survey
logo       
<prev   next>

Choosing A Webhost:
A web hosting service is a type of Internet hosting service that allows individuals and organizations to provide their own website accessible via the World Wide Web. Web hosts are companies that provide space on a server they own for use by their clients as well as providing Internet connectivity, typically in a data center. Web hosts can also provide data center space and connectivity to the Internet for servers they do not own to be located in their data center, called colocation. more...

cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server/dao IServerDAO.ja: msg#00196

apache.webservices.fx.devel

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/ServerDatabaseDAO.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.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;
}

}



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.java,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.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);
}

}
<Prev in Thread] Current Thread [Next in Thread>
Previous by Date:  cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server CompositeProcessor.java, jaliya-1oDqGaOF3Lkdnm+yROfE0A
Next by Date:  Re: cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server/dao IServerDAO.java ServerDatabaseDAO.java ServerQueueDAO.java, Sanjiva Weerawarana
Previous by Thread:  cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server CompositeProcessor.java, jaliya-1oDqGaOF3Lkdnm+yROfE0A
Next by Thread:  Re: cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server/dao IServerDAO.java ServerDatabaseDAO.java ServerQueueDAO.java, Sanjiva Weerawarana
Indexes:  [Date] [Thread] [Top] [All Lists]

Google Custom Search
Recently Viewed:
hardware.arm.at...    cms.citadel.dev...    video.gstreamer...    java.facelets.u...    misc.basics.qna...    web.wiki.instik...    network.uip.use...    xdg.devel/2003-...    tex.bibtex.bibd...    finance.quotesp...    ietf.zeroconf/2...    redhat.blinux.g...    suse.db2/2003-0...    php.phpesp/2004...    uml.devel/2003-...    gnome.labyrinth...    qnx.openqnx.dev...    boot-loaders.gr...    db.dataperfect....    audio.audacity....    linux.uclinux.m...    editors.j.devel...    os.openbsd.tech...    kde.users.multi...   
Home | advertise | OSDir is an inevitable website. super tiny logo

Free Magazines

Cisco News
Receive a free quarterly e-newsletter with exclusive articles on how Cisco IT uses its own products and solutions to enable the business.
subscribe

Systems Management News, the newspaper for IT systems administration and data center managers! Each issue of Systems Management News is chock-full of news and analysis to help you understand what's happening in your field.
subscribe

The Enterprise Newsweekly eWeek is the essential technology information source for builders of e-business.
subscribe

Oracle Magazine Oracle Magazine contains technology strategy articles, sample code, tips, Oracle and partner news, how to articles for developers and DBAs, and more. Oracle (NASDAQ: ORCL) is the world's largest enterprise software company.
subscribe

Total Telecom Total Telecom is "The Economist of the communications industry".
subscribe

Navigation