[CAMEL-19066] Multicast EIP sets correlationId on original Exchange

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 3.18.5, 3.20.2
• Fix Version/s: 3.18.6, 3.20.3, 3.21.0, 4.0-M2, 4.0.0
• Component/s: came-core
• Estimated Complexity: Unknown

Language

Java

• Assignee: Claus Ibsen
• Reporter: hgarus
• Created: 16/Feb/23 20:37
• Updated: 22/Feb/23 12:43
• Resolved: 22/Feb/23 12:43

Description

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:

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}'"); 

Which produces the following Logging output for a two-Element List:

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' 

Issue Links

• links to: GitHub Pull Request #9367
• links to: GitHub Pull Request #9392