Repository: camel Updated Branches: refs/heads/master a072a6cef -> 661cd5be9
CAMEL-11548: Making camel-undertow consumer InOut Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/661cd5be Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/661cd5be Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/661cd5be Branch: refs/heads/master Commit: 661cd5be9d82292d4b2414c61b54c15ca5911d65 Parents: a072a6c Author: Saravanakumar Selvaraj <saravanakumar.j...@gmail.com> Authored: Mon Jul 17 14:04:27 2017 +0530 Committer: Zoran Regvart <zregv...@apache.org> Committed: Mon Jul 17 10:51:08 2017 +0200 ---------------------------------------------------------------------- .../org/apache/camel/component/undertow/UndertowEndpoint.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/661cd5be/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowEndpoint.java b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowEndpoint.java index d4a39ff..16037c5 100644 --- a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowEndpoint.java +++ b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowEndpoint.java @@ -26,6 +26,7 @@ import io.undertow.server.HttpServerExchange; import org.apache.camel.AsyncEndpoint; import org.apache.camel.Consumer; import org.apache.camel.Exchange; +import org.apache.camel.ExchangePattern; import org.apache.camel.Message; import org.apache.camel.PollingConsumer; import org.apache.camel.Processor; @@ -126,7 +127,7 @@ public class UndertowEndpoint extends DefaultEndpoint implements AsyncEndpoint, } public Exchange createExchange(HttpServerExchange httpExchange) throws Exception { - Exchange exchange = createExchange(); + Exchange exchange = createExchange(ExchangePattern.InOut); Message in = getUndertowHttpBinding().toCamelMessage(httpExchange, exchange);
