svn commit: r941161 - in /cxf/trunk/rt: bindings/soap/src/main/java/org/apache/cxf/binding/soap/interceptor/ core/src/main/java/org/apache/cxf/endpoint/ transports/http/src/main/java/org/apache/cxf/transport/http/

[dkulp]

Author: dkulp
Date: Wed May  5 06:28:05 2010
New Revision: 941161

URL: http://svn.apache.org/viewvc?rev=941161&view=rev
Log:
[CXF-2792] Fix test failure introduced earlier

Modified:
    
cxf/trunk/rt/bindings/soap/src/main/java/org/apache/cxf/binding/soap/interceptor/SoapOutInterceptor.java
    cxf/trunk/rt/core/src/main/java/org/apache/cxf/endpoint/ClientImpl.java
    
cxf/trunk/rt/transports/http/src/main/java/org/apache/cxf/transport/http/HTTPConduit.java

Modified: 
cxf/trunk/rt/bindings/soap/src/main/java/org/apache/cxf/binding/soap/interceptor/SoapOutInterceptor.java
URL: 
http://svn.apache.org/viewvc/cxf/trunk/rt/bindings/soap/src/main/java/org/apache/cxf/binding/soap/interceptor/SoapOutInterceptor.java?rev=941161&r1=941160&r2=941161&view=diff
==============================================================================
--- 
cxf/trunk/rt/bindings/soap/src/main/java/org/apache/cxf/binding/soap/interceptor/SoapOutInterceptor.java
 (original)
+++ 
cxf/trunk/rt/bindings/soap/src/main/java/org/apache/cxf/binding/soap/interceptor/SoapOutInterceptor.java
 Wed May  5 06:28:05 2010
@@ -271,7 +271,6 @@ public class SoapOutInterceptor extends 
         }
 
         public void handleMessage(SoapMessage message) throws Fault {
-            SoapVersion soapVersion = message.getVersion();
             try {
                 XMLStreamWriter xtw = 
message.getContent(XMLStreamWriter.class);
                 if (xtw != null) {
@@ -283,6 +282,7 @@ public class SoapOutInterceptor extends 
                     xtw.flush();
                 }
             } catch (XMLStreamException e) {
+                SoapVersion soapVersion = message.getVersion();
                 throw new SoapFault(new 
org.apache.cxf.common.i18n.Message("XML_WRITE_EXC", BUNDLE), e,
                                     soapVersion.getSender());
             }

Modified: 
cxf/trunk/rt/core/src/main/java/org/apache/cxf/endpoint/ClientImpl.java
URL: 
http://svn.apache.org/viewvc/cxf/trunk/rt/core/src/main/java/org/apache/cxf/endpoint/ClientImpl.java?rev=941161&r1=941160&r2=941161&view=diff
==============================================================================
--- cxf/trunk/rt/core/src/main/java/org/apache/cxf/endpoint/ClientImpl.java 
(original)
+++ cxf/trunk/rt/core/src/main/java/org/apache/cxf/endpoint/ClientImpl.java Wed 
May  5 06:28:05 2010
@@ -70,6 +70,7 @@ import org.apache.cxf.service.model.Oper
 import org.apache.cxf.service.model.ServiceInfo;
 import org.apache.cxf.transport.Conduit;
 import org.apache.cxf.transport.MessageObserver;
+import org.apache.cxf.workqueue.SynchronousExecutor;
 import org.apache.cxf.wsdl11.WSDLServiceFactory;
 
 public class ClientImpl
@@ -944,7 +945,9 @@ public class ClientImpl
 
 
     public void setExecutor(Executor executor) {
-        this.executor = executor;
+        if (!SynchronousExecutor.isA(executor)) {
+            this.executor = executor;
+        }
     }
 
 

Modified: 
cxf/trunk/rt/transports/http/src/main/java/org/apache/cxf/transport/http/HTTPConduit.java
URL: 
http://svn.apache.org/viewvc/cxf/trunk/rt/transports/http/src/main/java/org/apache/cxf/transport/http/HTTPConduit.java?rev=941161&r1=941160&r2=941161&view=diff
==============================================================================
--- 
cxf/trunk/rt/transports/http/src/main/java/org/apache/cxf/transport/http/HTTPConduit.java
 (original)
+++ 
cxf/trunk/rt/transports/http/src/main/java/org/apache/cxf/transport/http/HTTPConduit.java
 Wed May  5 06:28:05 2010
@@ -2053,6 +2053,7 @@ public class HTTPConduit 
                         try {
                             handleResponseInternal();
                         } catch (Exception e) {
+                            
((PhaseInterceptorChain)outMessage.getInterceptorChain()).abort();
                             
((PhaseInterceptorChain)outMessage.getInterceptorChain()).unwind(outMessage);
                             outMessage.setContent(Exception.class, e);
                             
outMessage.getInterceptorChain().getFaultObserver().onMessage(outMessage);