You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ja...@apache.org on 2004/12/02 14:15:48 UTC
cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server CompositeProcessor.java
jaliya 2004/12/02 05:15:48
Modified: sandesha/src/org/apache/sandesha/server
CompositeProcessor.java
Log:
Composite processor needs to set the message numbe and the sequence number in the RMMessageContext before inserting to the queue
Revision Changes Path
1.11 +4 -1 ws-fx/sandesha/src/org/apache/sandesha/server/CompositeProcessor.java
Index: CompositeProcessor.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/CompositeProcessor.java,v
retrieving revision 1.10
retrieving revision 1.11
diff -u -r1.10 -r1.11
--- CompositeProcessor.java 24 Nov 2004 13:41:21 -0000 1.10
+++ CompositeProcessor.java 2 Dec 2004 13:15:48 -0000 1.11
@@ -53,10 +53,13 @@
.getIdentifier();
long messageNumber = rmHeaders.getSequence().getMessageNumber()
.getMessageNumber();
-
if (storageManger.isMessageExist(sequenceID, messageNumber) != true) {
//Create a copy of the RMMessageContext.
RMMessageContext rmMsgContext = new RMMessageContext();
+
+ System.out.println("SETTING THE RESPONSE "+sequenceID+" "+messageNumber) ;
+ rmMsgContext.setSequenceID(sequenceID);
+ rmMsgContext.setMsgNumber(messageNumber);
try {
//Copy the request and response messages.