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 <[email protected]>
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);
}
}