svn commit: r634606 - /webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java

[mckierna]

Author: mckierna
Date: Fri Mar  7 02:47:41 2008
New Revision: 634606

URL: http://svn.apache.org/viewvc?rev=634606&view=rev
Log:
SANDESHA2-141 Soap header issue

Modified:
    
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java

Modified: 
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java
URL: 
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java?rev=634606&r1=634605&r2=634606&view=diff
==============================================================================
--- 
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java
 (original)
+++ 
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java
 Fri Mar  7 02:47:41 2008
@@ -51,6 +51,7 @@
 import org.apache.sandesha2.storage.beans.SenderBean;
 import org.apache.sandesha2.util.FaultManager;
 import org.apache.sandesha2.util.MsgInitializer;
+import org.apache.sandesha2.util.SOAPAbstractFactory;
 import org.apache.sandesha2.util.SandeshaUtil;
 import org.apache.sandesha2.util.SpecSpecificConstants;
 import org.apache.sandesha2.workers.SandeshaThread;
@@ -308,6 +309,14 @@
        private static void addMessagePendingHeader (MessageContext 
returnMessage, String namespace) {
                MessagePending messagePending = new MessagePending();
                messagePending.setPending(true);
+               if(returnMessage.getEnvelope().getHeader() == null){
+                       int SOAPVersion = Sandesha2Constants.SOAPVersion.v1_1;
+                       if (!returnMessage.isSOAP11())
+                               SOAPVersion = 
Sandesha2Constants.SOAPVersion.v1_2;
+                       //The header might not be there because of the 
persistence code if it doesn't exist we need to add one
+                       SOAPAbstractFactory.getSOAPFactory(
+                                       
SOAPVersion).createSOAPHeader(returnMessage.getEnvelope());
+               }
                
messagePending.toHeader(returnMessage.getEnvelope().getHeader());
        }
 



---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]