jaliya 2005/01/11 05:49:34
Modified: sandesha/src/org/apache/sandesha IStorageManager.java
RMMessageContext.java
Log:
Added the functionality to send the TerminateSeq Msg at the client
Revision Changes Path
1.11 +1 -1
ws-fx/sandesha/src/org/apache/sandesha/IStorageManager.java
Index: IStorageManager.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/IStorageManager.java,v
retrieving revision 1.10
retrieving revision 1.11
diff -u -r1.10 -r1.11
--- IStorageManager.java 11 Jan 2005 07:12:33 -0000 1.10
+++ IStorageManager.java 11 Jan 2005 13:49:34 -0000 1.11
@@ -122,5 +122,5 @@
public void terminateSequence(String sequenceID);
- public void setAckReceived(RMMessageContext responseMsg);
+ public void setAckReceived(String seqId,long msgNo);
}
1.19 +5 -0
ws-fx/sandesha/src/org/apache/sandesha/RMMessageContext.java
Index: RMMessageContext.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/RMMessageContext.java,v
retrieving revision 1.18
retrieving revision 1.19
diff -u -r1.18 -r1.19
--- RMMessageContext.java 11 Jan 2005 07:13:35 -0000 1.18
+++ RMMessageContext.java 11 Jan 2005 13:49:34 -0000 1.19
@@ -336,6 +336,7 @@
rmMsgContext.setMsgContext(this.msgContext);
rmMsgContext.setReTransmissionCount(this.reTransmissionCount);
rmMsgContext.setLastPrecessedTime(this.lastPrecessedTime);
+ rmMsgContext.setLastMessage(this.isLastMessage());
}
@@ -421,6 +422,10 @@
// msgContext2.setService(msgContext1.getService());
if (msgContext1.getSession() != null)
+ msgContext2.setSession(msgContext1.getSession());
+
+
+ if (msgContext1.getSession() != null)
msgContext2.setSession(msgContext1.getSession());
if (msgContext1.getSOAPActionURI() != null)
