[jira] [Commented] (CAMEL-19066) Multicast EIP sets correlationId on original Exchange

["Claus Ibsen (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/CAMEL-19066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17690526#comment-17690526 ] 

Claus Ibsen commented on CAMEL-19066:
-------------------------------------

[~hgarus] would you add an unit test for enrich EIP also, and look at fixing org.apache.camel.processor.Enrich is a similar way.
BTW you should only restore the correlation id if its != null.

> Multicast EIP sets correlationId on original Exchange
> -----------------------------------------------------
>
>                 Key: CAMEL-19066
>                 URL: https://issues.apache.org/jira/browse/CAMEL-19066
>             Project: Camel
>          Issue Type: Bug
>          Components: came-core
>    Affects Versions: 3.18.5, 3.20.2
>            Reporter: hgarus
>            Assignee: Claus Ibsen
>            Priority: Minor
>
> When copying the result onto the original Exchange the Multicast EIP and related EIPs like Split and RecipientList copy the result back to the original Exchange, this copy includes the correlationId of the subexchange.
> This can be somewhat confusing, especially with FlexibleAggregationStrategy which aggregates the result in an Exchange which is correlated to a different Exchange than the original Exchange.
> Example:
> {code:java}
> from("direct:foo")
>     .log("Before split: exchangeId:'${exchangeId}' CorrelationId:'${exchangeProperty.CamelCorrelationId}'")
>     .split(body(), AggregationStrategies.flexible().pick(body()).accumulateInCollection(ArrayList.class))
>     .log("In split: exchangeId:'${exchangeId}' CorrelationId:'${exchangeProperty.CamelCorrelationId}'")
>     .end()
>     .log("After split: exchangeId:'${exchangeId}' CorrelationId:'${exchangeProperty.CamelCorrelationId}'"); {code}
> Which produces the following Logging output for a two-Element List:
> {code:java}
> Before split: exchangeId:'742F0530A58A761-0000000000000000' CorrelationId:''
> In split: exchangeId:'742F0530A58A761-0000000000000001' CorrelationId:'742F0530A58A761-0000000000000000'
> In split: exchangeId:'742F0530A58A761-0000000000000002' CorrelationId:'742F0530A58A761-0000000000000000'
> In split: exchangeId:'742F0530A58A761-0000000000000003' CorrelationId:'742F0530A58A761-0000000000000000'
> After split: exchangeId:'742F0530A58A761-0000000000000000' CorrelationId:'742F0530A58A761-0000000000000001' {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)