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 <[email protected]> Authored: Tue Mar 18 14:56:43 2014 -0400 Committer: Daniel Kulp <[email protected]> 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;
