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