You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by dk...@apache.org on 2014/03/18 19:57:44 UTC
git commit: [CXF-5564] Set the async flag based on whether the
exchange is async or not.
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 <dk...@apache.org>
Authored: Tue Mar 18 14:56:43 2014 -0400
Committer: Daniel Kulp <dk...@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;