You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by ml...@apache.org on 2007/02/02 11:17:56 UTC
svn commit: r502565 -
/webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java
Author: mlovett
Date: Fri Feb 2 02:17:55 2007
New Revision: 502565
URL: http://svn.apache.org/viewvc?view=rev&rev=502565
Log:
Ensure we always find the correct namespace for MessagePending headers
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java
Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java?view=diff&rev=502565&r1=502564&r2=502565
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java (original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java Fri Feb 2 02:17:55 2007
@@ -119,10 +119,9 @@
throw new SandeshaException (message);
}
- RMMsgContext returnRMMsg = MsgInitializer.initializeMessage(returnMessage);
-
- if(pending) addMessagePendingHeader (returnRMMsg,pending);
+ if(pending) addMessagePendingHeader(returnMessage, makeConnection.getNamespaceValue());
+ RMMsgContext returnRMMsg = MsgInitializer.initializeMessage(returnMessage);
setTransportProperties (returnMessage, rmMsgCtx);
// Link the response to the request
@@ -144,13 +143,10 @@
return false;
}
- private void addMessagePendingHeader (RMMsgContext returnMessage, boolean pending) throws SandeshaException {
- String rmNamespace = returnMessage.getRMNamespaceValue();
- MessagePending messagePending = new MessagePending (rmNamespace);
- messagePending.setPending(pending);
-
- messagePending.toSOAPEnvelope(returnMessage.getSOAPEnvelope());
-
+ private void addMessagePendingHeader (MessageContext returnMessage, String namespace) throws SandeshaException {
+ MessagePending messagePending = new MessagePending(namespace);
+ messagePending.setPending(true);
+ messagePending.toSOAPEnvelope(returnMessage.getEnvelope());
}
public boolean processOutMessage(RMMsgContext rmMsgCtx) throws AxisFault {
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org