cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dk...@apache.org
Subject git commit: [CXF-5564] Set the async flag based on whether the exchange is async or not.
Date Tue, 18 Mar 2014 18:57:44 GMT
Repository: cxf
Updated Branches:
  refs/heads/master d05e1a988 -> 9bb928f75


[CXF-5564] Set the async flag based on whether the exchange is async or not.


Project: http://git-wip-us.apache.org/repos/asf/cxf/repo
Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/9bb928f7
Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/9bb928f7
Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/9bb928f7

Branch: refs/heads/master
Commit: 9bb928f7541c61a8a47c6a89db95155aad3153d0
Parents: d05e1a9
Author: Daniel Kulp <dkulp@apache.org>
Authored: Tue Mar 18 14:56:43 2014 -0400
Committer: Daniel Kulp <dkulp@apache.org>
Committed: Tue Mar 18 14:56:43 2014 -0400

----------------------------------------------------------------------
 .../apache/cxf/transport/http/asyncclient/AsyncHTTPConduit.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cxf/blob/9bb928f7/rt/transports/http-hc/src/main/java/org/apache/cxf/transport/http/asyncclient/AsyncHTTPConduit.java
----------------------------------------------------------------------
diff --git a/rt/transports/http-hc/src/main/java/org/apache/cxf/transport/http/asyncclient/AsyncHTTPConduit.java
b/rt/transports/http-hc/src/main/java/org/apache/cxf/transport/http/asyncclient/AsyncHTTPConduit.java
index a766dcf..c061b54 100644
--- a/rt/transports/http-hc/src/main/java/org/apache/cxf/transport/http/asyncclient/AsyncHTTPConduit.java
+++ b/rt/transports/http-hc/src/main/java/org/apache/cxf/transport/http/asyncclient/AsyncHTTPConduit.java
@@ -280,6 +280,8 @@ public class AsyncHTTPConduit extends URLConnectionHTTPConduit {
             int bufSize = csPolicy.getChunkLength() > 0 ? csPolicy.getChunkLength() :
16320;
             inbuf = new SharedInputBuffer(bufSize, allocator);
             outbuf = new SharedOutputBuffer(bufSize, allocator);
+            isAsync = outMessage != null && outMessage.getExchange() != null 
+                && !outMessage.getExchange().isSynchronous();
         }
         
         public boolean retransmitable() {
@@ -791,7 +793,8 @@ public class AsyncHTTPConduit extends URLConnectionHTTPConduit {
 
         protected void setupNewConnection(String newURL) throws IOException {
             httpResponse = null;
-            isAsync = false;
+            isAsync = outMessage != null && outMessage.getExchange() != null 
+                && !outMessage.getExchange().isSynchronous();
             exception = null;
             connectionFuture = null;
             session = null;


Mime
View raw message