Skip to content

Commit 6e1f62a

Browse files
committed
Make sure SSL works as well
1 parent 8a0a46a commit 6e1f62a

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

src/main/java/com/ning/http/client/providers/netty/NettyAsyncHttpProvider.java

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -404,7 +404,13 @@ protected final <T> void writeRequest(final Channel channel,
404404
String boundary = future.getNettyRequest().getHeader("Content-Type");
405405
String length = future.getNettyRequest().getHeader("Content-Length");
406406
final MultipartBody multipartBody = new MultipartBody(future.getRequest().getParts(), boundary, length);
407-
ChannelFuture writeFuture = channel.write(new BodyFileRegion(multipartBody));
407+
408+
ChannelFuture writeFuture;
409+
if (channel.getPipeline().get(SslHandler.class) == null) {
410+
writeFuture = channel.write(new BodyFileRegion(multipartBody));
411+
} else {
412+
writeFuture = channel.write(new BodyChunkedInput(multipartBody));
413+
}
408414

409415
writeFuture.addListener(new ProgressListener(false, future.getAsyncHandler(), future) {
410416

@@ -700,7 +706,6 @@ private static HttpRequest construct(AsyncHttpClientConfig config,
700706

701707
nettyRequest.setHeader(HttpHeaders.Names.CONTENT_TYPE, mre.getContentType());
702708
nettyRequest.setHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(mre.getContentLength()));
703-
704709
} else if (request.getEntityWriter() != null) {
705710
int lenght = computeAndSetContentLength(request, nettyRequest);
706711

0 commit comments

Comments
 (0)