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/10/06 14:59:03 UTC
cvs commit: ws-fx/sandesha/src/org/apache/sandesha/server AcknowledgementProcessor.java
jaliya 2004/10/06 05:59:03
Modified: sandesha/src/org/apache/sandesha/server
AcknowledgementProcessor.java
Log:
Added the support for the old anonymous URI. This can be removed after the testing stage
Revision Changes Path
1.7 +8 -5 ws-fx/sandesha/src/org/apache/sandesha/server/AcknowledgementProcessor.java
Index: AcknowledgementProcessor.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/server/AcknowledgementProcessor.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -u -r1.6 -r1.7
--- AcknowledgementProcessor.java 13 Sep 2004 11:26:32 -0000 1.6
+++ AcknowledgementProcessor.java 6 Oct 2004 12:59:03 -0000 1.7
@@ -111,6 +111,8 @@
rmMsgContext.setMsgContext(msgContext);
//Get the from address to send the Ack.
+ //Doesn't matter whether we have Sync or ASync messages.
+ //If we have Sync them this property is not used.
rmMsgContext.setOutGoingAddress(rmMessageContext
.getAddressingHeaders().getFrom().getAddress().toString());
//Set the messsage type
@@ -119,12 +121,14 @@
e.printStackTrace();
//TODO: Log the error
}
-
- if ((rmMessageContext.getAddressingHeaders().getFrom().getAddress()
+
+ //FIX THIS FIX THIS //FIX THIS FIX THIS //FIX THIS FIX THIS
+ //Need to change this to the new Anonymous URI.
+ if (((rmMessageContext.getAddressingHeaders().getFrom().getAddress()
.toString()
- .equals(org.apache.axis.message.addressing.Constants.NS_URI_ANONYMOUS)) == true) {
+ .equals(org.apache.axis.message.addressing.Constants.NS_URI_ANONYMOUS)) == true)||(rmMessageContext.getAddressingHeaders().getFrom().getAddress()
+ .toString().equals("http://schemas.xmlsoap.org/ws/2003/03/addressing/role/anonymous"))) {
//Now we have synchronized ack.
-
//The original message context is used to send the ack
// asynchronously to the client.
//So the response message is replaced by the new ack message.
@@ -132,7 +136,6 @@
new Message(ackEnvelope));
return true;
} else {
-
//Store the asynchronize ack in the queue.
//The name for this queue is not yet fixed.
//RENAME insertAcknowledgement(rmMessageContext)