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 d880f83 CAMEL-16222: PooledExchangeFactory experiment d880f83 is described below commit d880f8363ffda963c0c0044a51a479cb4d14726c Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Wed Feb 24 06:57:47 2021 +0100 CAMEL-16222: PooledExchangeFactory experiment --- .../resources/archetype-resources/src/main/java/__name__Consumer.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/__name__Consumer.java b/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/__name__Consumer.java index 0faa760..0721efd 100644 --- a/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/__name__Consumer.java +++ b/archetypes/camel-archetype-component/src/main/resources/archetype-resources/src/main/java/__name__Consumer.java @@ -57,7 +57,7 @@ public class ${name}Consumer extends DefaultConsumer { } private void onEventListener(final Object event) { - final Exchange exchange = endpoint.createExchange(); + final Exchange exchange = createExchange(false); exchange.getIn().setBody("Hello World! The time is " + event); @@ -70,6 +70,7 @@ public class ${name}Consumer extends DefaultConsumer { if (exchange.getException() != null) { getExceptionHandler().handleException("Error processing exchange", exchange, exchange.getException()); } + releaseExchange(exchange, false); } } }