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

commit 53498894c20d6b79dc23ed8c4dfcd3b8373f2055
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Feb 22 16:41:54 2021 +0100

    CAMEL-16222: PooledExchangeFactory experiment
---
 .../component/file/remote/RemoteFileIgnoreDoPollErrorTest.java    | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/RemoteFileIgnoreDoPollErrorTest.java
 
b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/RemoteFileIgnoreDoPollErrorTest.java
index ade11ef..371aaac 100644
--- 
a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/RemoteFileIgnoreDoPollErrorTest.java
+++ 
b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/RemoteFileIgnoreDoPollErrorTest.java
@@ -20,6 +20,7 @@ import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 
+import org.apache.camel.CamelContext;
 import org.apache.camel.Exchange;
 import org.apache.camel.Message;
 import org.apache.camel.Processor;
@@ -27,6 +28,7 @@ import org.apache.camel.component.file.GenericFile;
 import org.apache.camel.component.file.GenericFileOperationFailedException;
 import org.apache.camel.component.file.GenericFileProcessStrategy;
 import org.apache.camel.component.file.GenericFileProducer;
+import org.apache.camel.impl.DefaultCamelContext;
 import org.junit.jupiter.api.Test;
 
 import static org.junit.jupiter.api.Assertions.assertFalse;
@@ -35,6 +37,9 @@ import static org.junit.jupiter.api.Assertions.assertThrows;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
 public class RemoteFileIgnoreDoPollErrorTest {
+
+    private final CamelContext camelContext = new DefaultCamelContext();
+
     private final RemoteFileEndpoint<Object> remoteFileEndpoint = new 
RemoteFileEndpoint<Object>() {
         @Override
         protected RemoteFileConsumer<Object> buildConsumer(Processor 
processor) {
@@ -100,6 +105,9 @@ public class RemoteFileIgnoreDoPollErrorTest {
 
     private RemoteFileConsumer<Object> getRemoteFileConsumer(
             final String doPollResult, final boolean ignoreCannotRetrieveFile) 
{
+
+        remoteFileEndpoint.setCamelContext(camelContext);
+
         return new RemoteFileConsumer<Object>(remoteFileEndpoint, null, null, 
null) {
             @Override
             protected boolean doPollDirectory(