This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch exchange-factory in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/exchange-factory by this push: new 4432569 CAMEL-16222: PooledExchangeFactory experiment 4432569 is described below commit 4432569c49c3ab35c705d9efb4b64d1ba90ddf0e Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Tue Feb 23 09:26:09 2021 +0100 CAMEL-16222: PooledExchangeFactory experiment --- .../org/apache/camel/component/jetty/CamelContinuationServlet.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/CamelContinuationServlet.java b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/CamelContinuationServlet.java index 013e00d..fdd4974 100644 --- a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/CamelContinuationServlet.java +++ b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/CamelContinuationServlet.java @@ -181,7 +181,8 @@ public class CamelContinuationServlet extends CamelServlet { } // a new request so create an exchange - final Exchange exchange = consumer.getEndpoint().createExchange(ExchangePattern.InOut); + final Exchange exchange = consumer.createExchange(false); + exchange.setPattern(ExchangePattern.InOut); if (consumer.getEndpoint().isBridgeEndpoint()) { exchange.setProperty(Exchange.SKIP_GZIP_ENCODING, Boolean.TRUE); @@ -268,6 +269,7 @@ public class CamelContinuationServlet extends CamelServlet { throw new ServletException(e); } finally { consumer.doneUoW(result); + consumer.releaseExchange(result, false); } }