[camel] branch main updated: CAMEL-19568: disable header validation on camel-netty-http

[orpiske]

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new f27fb40c3b1 CAMEL-19568: disable header validation on camel-netty-http
f27fb40c3b1 is described below

commit f27fb40c3b1143e6e26fcb3da7d8a5caacf4d37c
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Tue Jul 18 16:36:47 2023 +0200

    CAMEL-19568: disable header validation on camel-netty-http
    
    Netty seems to complain about the content-type header when dealing with 
multipart messages. This disables the header validation so that those headers 
can go through.
---
 .../camel/component/netty/http/DefaultNettyHttpBinding.java       | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/DefaultNettyHttpBinding.java
 
b/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/DefaultNettyHttpBinding.java
index 4d8fbd93b7a..a0817b20a28 100644
--- 
a/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/DefaultNettyHttpBinding.java
+++ 
b/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/DefaultNettyHttpBinding.java
@@ -461,7 +461,7 @@ public class DefaultNettyHttpBinding implements 
NettyHttpBinding, Cloneable {
 
         if (body instanceof InputStream && 
configuration.isDisableStreamCache()) {
             response = new OutboundStreamHttpResponse(
-                    (InputStream) body, new 
DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.valueOf(code)));
+                    (InputStream) body, new 
DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.valueOf(code), 
false));
             response.headers().set(TRANSFER_ENCODING, CHUNKED);
         }
 
@@ -490,7 +490,7 @@ public class DefaultNettyHttpBinding implements 
NettyHttpBinding, Cloneable {
             }
 
             if (buffer != null) {
-                response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, 
HttpResponseStatus.valueOf(code), buffer);
+                response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, 
HttpResponseStatus.valueOf(code), buffer, false);
                 // We just need to reset the readerIndex this time
                 if (buffer.readerIndex() == buffer.writerIndex()) {
                     buffer.setIndex(0, buffer.writerIndex());
@@ -501,7 +501,7 @@ public class DefaultNettyHttpBinding implements 
NettyHttpBinding, Cloneable {
                 
response.headers().set(HttpHeaderNames.CONTENT_LENGTH.toString(), len);
                 LOG.trace("Content-Length: {}", len);
             } else {
-                response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, 
HttpResponseStatus.valueOf(code));
+                response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, 
HttpResponseStatus.valueOf(code), false);
             }
         }
 
@@ -528,8 +528,8 @@ public class DefaultNettyHttpBinding implements 
NettyHttpBinding, Cloneable {
         String contentType = MessageHelper.getContentType(message);
         if (contentType != null) {
             // set content-type
-            response.headers().set(HttpHeaderNames.CONTENT_TYPE.toString(), 
contentType);
             LOG.trace("Content-Type: {}", contentType);
+            response.headers().set(HttpHeaderNames.CONTENT_TYPE.toString(), 
contentType);
         }
 
         // configure connection to accordingly to keep alive configuration