cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject svn commit: r735252 - in /cxf/trunk: api/src/main/java/org/apache/cxf/endpoint/Client.java rt/core/src/main/java/org/apache/cxf/endpoint/ClientImpl.java
Date Sat, 17 Jan 2009 08:41:02 GMT
Author: ningjiang
Date: Sat Jan 17 00:41:02 2009
New Revision: 735252

URL: http://svn.apache.org/viewvc?rev=735252&view=rev
Log:
CXF-1989 applied patch with thanks to William

Modified:
    cxf/trunk/api/src/main/java/org/apache/cxf/endpoint/Client.java
    cxf/trunk/rt/core/src/main/java/org/apache/cxf/endpoint/ClientImpl.java

Modified: cxf/trunk/api/src/main/java/org/apache/cxf/endpoint/Client.java
URL: http://svn.apache.org/viewvc/cxf/trunk/api/src/main/java/org/apache/cxf/endpoint/Client.java?rev=735252&r1=735251&r2=735252&view=diff
==============================================================================
--- cxf/trunk/api/src/main/java/org/apache/cxf/endpoint/Client.java (original)
+++ cxf/trunk/api/src/main/java/org/apache/cxf/endpoint/Client.java Sat Jan 17 00:41:02 2009
@@ -33,6 +33,7 @@
 public interface Client extends InterceptorProvider, MessageObserver {
     String REQUEST_CONTEXT = "RequestContext";
     String RESPONSE_CONTEXT = "ResponseContext";
+    String KEEP_CONDUIT_ALIVE = "KeepConduitAlive";
 
     /**
      * Invokes an operation synchronously

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=735252&r1=735251&r2=735252&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 Sat Jan 17 00:41:02
2009
@@ -503,7 +503,12 @@
                 waitResponse(exchange);
             }
         }
-        getConduitSelector().complete(exchange);
+        
+        // leave the input stream open for the caller
+        Boolean keepConduitAlive = (Boolean)exchange.get(Client.KEEP_CONDUIT_ALIVE);
+        if (keepConduitAlive == null || !keepConduitAlive) {
+            getConduitSelector().complete(exchange);
+        }
 
         // Grab the response objects if there are any
         List resList = null;



Mime
View raw message