[camel] branch exchange-factory updated: CAMEL-16222: PooledExchangeFactory experiment

[davsclaus]

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 ea5772c  CAMEL-16222: PooledExchangeFactory experiment
ea5772c is described below

commit ea5772c9a347c77c3b9d71f6a62f905bc4d7fe9b
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Feb 22 17:27:00 2021 +0100

    CAMEL-16222: PooledExchangeFactory experiment
---
 .../apache/camel/component/yammer/YammerMessagePollingConsumer.java    | 3 ++-
 .../org/apache/camel/component/yammer/YammerUserPollingConsumer.java   | 3 ++-
 .../java/org/apache/camel/component/zookeeper/ZooKeeperConsumer.java   | 2 +-
 3 files changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerMessagePollingConsumer.java
 
b/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerMessagePollingConsumer.java
index 2508cf7..fe218f9 100644
--- 
a/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerMessagePollingConsumer.java
+++ 
b/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerMessagePollingConsumer.java
@@ -115,7 +115,7 @@ public class YammerMessagePollingConsumer extends 
ScheduledPollConsumer {
 
     @Override
     protected int poll() throws Exception {
-        Exchange exchange = endpoint.createExchange();
+        Exchange exchange = createExchange(false);
 
         try {
             String jsonBody = requestor.get();
@@ -137,6 +137,7 @@ public class YammerMessagePollingConsumer extends 
ScheduledPollConsumer {
             if (exchange.getException() != null) {
                 getExceptionHandler().handleException("Error processing 
exchange", exchange, exchange.getException());
             }
+            releaseExchange(exchange, false);
         }
     }
 
diff --git 
a/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerUserPollingConsumer.java
 
b/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerUserPollingConsumer.java
index 745ac3a..e9cde17 100644
--- 
a/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerUserPollingConsumer.java
+++ 
b/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerUserPollingConsumer.java
@@ -69,7 +69,7 @@ public class YammerUserPollingConsumer extends 
ScheduledPollConsumer {
 
     @Override
     protected int poll() throws Exception {
-        Exchange exchange = endpoint.createExchange();
+        Exchange exchange = createExchange(false);
 
         try {
             String jsonBody = requestor.get();
@@ -105,6 +105,7 @@ public class YammerUserPollingConsumer extends 
ScheduledPollConsumer {
             if (exchange.getException() != null) {
                 getExceptionHandler().handleException("Error processing 
exchange", exchange, exchange.getException());
             }
+            releaseExchange(exchange, false);
         }
     }
 
diff --git 
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperConsumer.java
 
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperConsumer.java
index 1b386c5..b646ca3 100644
--- 
a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperConsumer.java
+++ 
b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperConsumer.java
@@ -113,7 +113,7 @@ public class ZooKeeperConsumer extends DefaultConsumer {
     }
 
     private Exchange createExchange(String path, OperationResult result, 
WatchedEvent watchedEvent) {
-        Exchange exchange = getEndpoint().createExchange();
+        Exchange exchange = createExchange(true);
         ZooKeeperMessage in = new 
ZooKeeperMessage(getEndpoint().getCamelContext(), path, result.getStatistics(), 
watchedEvent);
         exchange.setIn(in);
         if (result.isOk()) {