Followup to CAMEL-8072

Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/90ce8ab4
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/90ce8ab4
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/90ce8ab4

Branch: refs/heads/master
Commit: 90ce8ab426c3c091efc470f01346d1435edac58d
Parents: 6692e93
Author: Yoshiki Higo <yoshiki.h...@gmail.com>
Authored: Wed Aug 24 17:15:59 2016 +0900
Committer: Andrea Cosentino <anco...@gmail.com>
Committed: Fri Aug 26 13:41:26 2016 +0200

----------------------------------------------------------------------
 .../component/netty/http/handlers/HttpServerChannelHandler.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/90ce8ab4/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/handlers/HttpServerChannelHandler.java
----------------------------------------------------------------------
diff --git 
a/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/handlers/HttpServerChannelHandler.java
 
b/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/handlers/HttpServerChannelHandler.java
index a1d8a26..cf8936a 100644
--- 
a/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/handlers/HttpServerChannelHandler.java
+++ 
b/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/handlers/HttpServerChannelHandler.java
@@ -110,7 +110,8 @@ public class HttpServerChannelHandler extends 
ServerChannelHandler {
             response.headers().set("Allow", s);
             response.headers().set(Exchange.CONTENT_TYPE, "text/plain");
             response.headers().set(Exchange.CONTENT_LENGTH, 0);
-            messageEvent.getChannel().write(response);
+            messageEvent.getChannel().write(response).syncUninterruptibly();
+            messageEvent.getChannel().close();
             return;
         }
         if (consumer.getEndpoint().getHttpMethodRestrict() != null

Reply via email to