chamikara 2005/01/10 15:00:09
Modified: sandesha/src/org/apache/sandesha/server RMInvoker.java
Log:
adding terminate sequence message, when the last message get evaluated
Revision Changes Path
1.7 +7 -5
ws-fx/sandesha/src/org/apache/sandesha/server/RMInvoker.java
Index: RMInvoker.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/RMInvoker.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -u -r1.6 -r1.7
--- RMInvoker.java 24 Nov 2004 13:38:36 -0000 1.6
+++ RMInvoker.java 10 Jan 2005 23:00:09 -0000 1.7
@@ -71,6 +71,11 @@
//configurable entity where the class can be loaded at
// runtime.
RPCProvider rpcProvider = new RPCProvider();
+
+ if(rmMessageContext.isLastMessage()){
+ //Insert Terminate Sequnce.
+
//storageManager.insertTerminateSeqMessage(getTerminateSeqMessage(requestMesssageContext));
+ }
rpcProvider.invoke(rmMessageContext.getMsgContext());
//Check whether we have an output (response) or not.
@@ -89,12 +94,9 @@
.setMessageType(Constants.MSG_TYPE_SERVICE_RESPONSE);
//System.out.println("TESTING FOR RESPONSE
SEQUENCE");
-
boolean firstMsgOfResponseSeq = !storageManager
- .isResponseSequenceExist(rmMessageContext
- .getSequenceID());
- rmMessageContext.setMsgNumber(storageManager
- .getNextMessageNumber(rmMessageContext
+
.isResponseSequenceExist(rmMessageContext.getSequenceID());
+
rmMessageContext.setMsgNumber(storageManager.getNextMessageNumber(rmMessageContext
.getSequenceID()));
////System.out.println("SEQUENCE ID -
// "+rmMessageContext.getSequenceID());
