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 sn...@apache.org on 2004/05/11 10:25:46 UTC
cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server MessageInserter.java
snimalan 2004/05/11 01:25:46
Modified: sandesha/src/org/apache/sandesha/server MessageInserter.java
Log:
Add code to send the ack for Respoce messages
Revision Changes Path
1.9 +8 -2 ws-fx/sandesha/src/org/apache/sandesha/server/MessageInserter.java
Index: MessageInserter.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/MessageInserter.java,v
retrieving revision 1.8
retrieving revision 1.9
diff -u -r1.8 -r1.9
--- MessageInserter.java 7 May 2004 17:39:38 -0000 1.8
+++ MessageInserter.java 11 May 2004 08:25:46 -0000 1.9
@@ -215,18 +215,20 @@
}
}
+ //sending ack
+
if (rmMessage != null) {
rmMessage.setIdentifier(
rmHeaders.getSequence().getIdentifier());
RMSequence rmSeq;
rmSeq =
- clientMessageController.retrieveIfSequenceExists(
+ serverMessageController.retrieveIfSequenceExists(
rmMessage.getIdentifier());
if (rmSeq == null) {
rmSeq = new RMSequence();
rmSeq.setSequenceIdentifier(
rmMessage.getIdentifier());
- clientMessageController.storeSequence(rmSeq);
+ serverMessageController.storeSequence(rmSeq);
}
rmMessage.setRMHeaders(rmHeaders);
rmMessage.setMessageNumber(
@@ -254,6 +256,10 @@
new URI(Constants.RM_SEQUENCE_ACKNOWLEDMENT_ACTION);
Action action = new Action(actionURI);
action.toSOAPHeaderElement(ackResEnv);
+ Message msg=new Message(ackResEnv);
+ Call call=new Call(resTo.toString());
+ call.setRequestMessage(msg);
+ call.invoke();
}
}
}