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);
         }
     }
 }

Reply via email to