jaliya 2005/01/11 05:59:24
Modified: sandesha/src/org/apache/sandesha/ws/rm LastMessage.java
sandesha/src/org/apache/sandesha/ws/rm/providers
RMProvider.java
Log:
Added functionality to send the TerminateSeq message from the Client
Revision Changes Path
1.10 +1 -1
ws-fx/sandesha/src/org/apache/sandesha/ws/rm/LastMessage.java
Index: LastMessage.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/ws/rm/LastMessage.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -u -r1.9 -r1.10
--- LastMessage.java 10 Jan 2005 23:03:37 -0000 1.9
+++ LastMessage.java 11 Jan 2005 13:59:24 -0000 1.10
@@ -68,7 +68,7 @@
* @return LastMessage
*/
public LastMessage fromSOAPEnvelope(MessageElement element) {
- return this;
+ return this;
}
/**
1.23 +8 -6
ws-fx/sandesha/src/org/apache/sandesha/ws/rm/providers/RMProvider.java
Index: RMProvider.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/ws/rm/providers/RMProvider.java,v
retrieving revision 1.22
retrieving revision 1.23
diff -u -r1.22 -r1.23
--- RMProvider.java 11 Jan 2005 07:23:39 -0000 1.22
+++ RMProvider.java 11 Jan 2005 13:59:24 -0000 1.23
@@ -77,11 +77,14 @@
RMMessageContext rmMessageContext = new RMMessageContext();
if (rmHeaders.getSequence() != null) {
- rmMessageContext.setSequenceID(rmHeaders.getSequence()
- .getIdentifier().toString());
- //System.out.println("SEQ ID :
- // "+rmHeaders.getSequence().getIdentifier().toString());
+
rmMessageContext.setSequenceID(rmHeaders.getSequence().getIdentifier().toString());
+
+ if(rmHeaders.getSequence().getLastMessage()!=null){
+ System.out.println("SETTING THE LAST MESSAGE");
+ rmMessageContext.setLastMessage(true);
+ }
}
+
if (addressingHeaders.getMessageID() != null) {
rmMessageContext.setMessageID(addressingHeaders.getMessageID()
.toString());
@@ -98,8 +101,7 @@
rmMessageContext.setMsgContext(msgContext);
rmMessageContext.setAddressingHeaders(addressingHeaders);
rmMessageContext.setRMHeaders(rmHeaders);
- if(rmHeaders.getSequence()!=null &&
rmHeaders.getSequence().getLastMessage()!=null)
- rmMessageContext.setLastMessage(true);
+
new RMMessageProcessorIdentifier();
IRMMessageProcessor rmMessageProcessor = RMMessageProcessorIdentifier
