[camel] branch camel-2.x updated: CAMEL-13428: camel-undertow - Response with large data gets truncated on cloud

[acosentino]

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

acosentino pushed a commit to branch camel-2.x
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/camel-2.x by this push:
     new 83b76f8  CAMEL-13428: camel-undertow - Response with large data gets 
truncated on cloud
83b76f8 is described below

commit 83b76f8e1b9f4f4dbe43992b9a45651747d06426
Author: Tadayoshi Sato <sato.tadayo...@gmail.com>
AuthorDate: Thu Apr 18 11:39:04 2019 +0900

    CAMEL-13428: camel-undertow - Response with large data gets truncated on 
cloud
---
 .../java/org/apache/camel/component/undertow/UndertowConsumer.java     | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConsumer.java
 
b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConsumer.java
index 2315349..bcdec14 100644
--- 
a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConsumer.java
+++ 
b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowConsumer.java
@@ -124,7 +124,7 @@ public class UndertowConsumer extends DefaultConsumer 
implements HttpHandler {
             
httpExchange.getResponseHeaders().put(ExchangeHeaders.CONTENT_LENGTH, 0);
             // do not include content-type as that would indicate to the 
caller that we can only do text/plain
             httpExchange.getResponseHeaders().put(Headers.ALLOW, 
allowedMethods);
-            httpExchange.getResponseSender().close();
+            httpExchange.endExchange();
             return;
         }
 
@@ -159,7 +159,6 @@ public class UndertowConsumer extends DefaultConsumer 
implements HttpHandler {
             ByteBuffer bodyAsByteBuffer = tc.convertTo(ByteBuffer.class, body);
             httpExchange.getResponseSender().send(bodyAsByteBuffer);
         }
-        httpExchange.getResponseSender().close();
     }
 
     /**