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();