You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2021/04/06 10:05:31 UTC

[camel] 04/04: CAMEL-16451: camel-core - ExchangePooling for EIPs. Enricher EIP

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 0b0e3882fac9fc81d22563ffc9e05845639061b7
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Tue Apr 6 11:48:35 2021 +0200

    CAMEL-16451: camel-core - ExchangePooling for EIPs. Enricher EIP
---
 .../src/main/java/org/apache/camel/processor/Enricher.java              | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/Enricher.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/Enricher.java
index 8c5095a..847fe72 100644
--- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/Enricher.java
+++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/Enricher.java
@@ -421,6 +421,8 @@ public class Enricher extends AsyncProcessorSupport implements IdAware, RouteIdA
         // create a per processor exchange factory
         this.processorExchangeFactory = getCamelContext().adapt(ExtendedCamelContext.class)
                 .getProcessorExchangeFactory().newProcessorExchangeFactory(this);
+        this.processorExchangeFactory.setRouteId(getRouteId());
+        this.processorExchangeFactory.setId(getId());
 
         if (aggregationStrategy == null) {
             aggregationStrategy = defaultAggregationStrategy();