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
commit fbd0f47caafb423d6742bfb2ac03a74808cc1437 Author: Claus Ibsen <[email protected]> AuthorDate: Sat Feb 20 17:38:13 2021 +0100 CAMEL-16222: PooledExchangeFactory experiment --- .../main/java/org/apache/camel/impl/engine/SimpleCamelContext.java | 2 +- .../src/main/java/org/apache/camel/support/DefaultConsumer.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/SimpleCamelContext.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/SimpleCamelContext.java index 2ec85fa..b91710c 100644 --- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/SimpleCamelContext.java +++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/SimpleCamelContext.java @@ -551,7 +551,7 @@ public class SimpleCamelContext extends AbstractCamelContext { ExchangeFactory.FACTORY, ExchangeFactory.class); - return result.orElseGet(DefaultExchangeFactory::new); + return result.orElseGet(DefaultExchangeFactory::new); } @Override diff --git a/core/camel-support/src/main/java/org/apache/camel/support/DefaultConsumer.java b/core/camel-support/src/main/java/org/apache/camel/support/DefaultConsumer.java index 2bd8cc2..1a07341 100644 --- a/core/camel-support/src/main/java/org/apache/camel/support/DefaultConsumer.java +++ b/core/camel-support/src/main/java/org/apache/camel/support/DefaultConsumer.java @@ -136,9 +136,9 @@ public class DefaultConsumer extends ServiceSupport implements Consumer, RouteAw @Override public void releaseExchange(Exchange exchange, boolean autoRelease) { if (exchange != null) { - if (!autoRelease) { + if (!autoRelease && exchange instanceof PooledExchange) { // if not auto release we must manually force done - exchange.adapt(PooledExchange.class).done(true); + ((PooledExchange) exchange).done(true); } exchangeFactory.release(exchange); }
