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

commit b22c6839012c1a45ad24dc119cfca0d45e82bba1
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Feb 22 08:15:20 2021 +0100

    CAMEL-16222: PooledExchangeFactory experiment
---
 .../main/java/org/apache/camel/component/mail/MailEndpoint.java    | 7 +++++++
 .../camel/component/mongodb/MongoDbChangeStreamsConsumer.java      | 3 ---
 2 files changed, 7 insertions(+), 3 deletions(-)

diff --git 
a/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailEndpoint.java
 
b/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailEndpoint.java
index 1ce1be9..c7723cd 100644
--- 
a/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailEndpoint.java
+++ 
b/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailEndpoint.java
@@ -126,6 +126,13 @@ public class MailEndpoint extends ScheduledPollEndpoint 
implements HeaderFilterS
         return answer;
     }
 
+    public Exchange createExchange(Message message) {
+        Exchange exchange = super.createExchange();
+        exchange.setProperty(Exchange.BINDING, getBinding());
+        exchange.setIn(new MailMessage(exchange, message, 
getConfiguration().isMapMailMessage()));
+        return exchange;
+    }
+
     // Properties
     // 
-------------------------------------------------------------------------
 
diff --git 
a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbChangeStreamsConsumer.java
 
b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbChangeStreamsConsumer.java
index 4fd3b23..62cf9bb 100644
--- 
a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbChangeStreamsConsumer.java
+++ 
b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbChangeStreamsConsumer.java
@@ -19,13 +19,10 @@ package org.apache.camel.component.mongodb;
 import java.util.List;
 import java.util.concurrent.ExecutorService;
 
-import org.apache.camel.Exchange;
-import org.apache.camel.Message;
 import org.apache.camel.Processor;
 import org.apache.camel.support.DefaultConsumer;
 import org.apache.camel.util.ObjectHelper;
 import org.bson.BsonDocument;
-import org.bson.Document;
 
 import static java.util.Collections.singletonList;