[
https://issues.apache.org/jira/browse/CAMEL-16295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301611#comment-17301611
]
Tom Cassimon commented on CAMEL-16295:
--------------------------------------
Hi,
i've tried the new 3.7.3 LTS release but the problem still persists.
If I debug the MulticastProcessor class the sequence of execution seems wrong
in the MulticastTransactedTask (on line 589 - 593):
{code:java}
// accept the exchange as a result
completion.submit(exchangeResult -> exchangeResult.accept(exchange));
// aggregate exchanges if any
aggregate();{code}
The aggregate method is called before the exchangeResult.accept(exchange) what
leads to an empty completion.poll() on line 355 of the code, so no aggregation
is done. In the MulticastReactiveTask the aggregate is called inside the
completion.submit function, should this not be the same in the
MulticastTransactedTask?
{code:java}
completion.submit(exchangeResult -> {
// accept the exchange as a result
exchangeResult.accept(exchange));
// aggregate exchanges if any
aggregate();
}{code}
Am i missing something here?
> split with AggregationStrategy is ignored when using transacted
> ---------------------------------------------------------------
>
> Key: CAMEL-16295
> URL: https://issues.apache.org/jira/browse/CAMEL-16295
> Project: Camel
> Issue Type: Bug
> Components: camel-core
> Affects Versions: 3.8.0
> Reporter: Sita Geßner
> Assignee: Claus Ibsen
> Priority: Major
> Fix For: 3.7.3, 3.9.0
>
>
> After migration from Camel 2.25.x to Camel 3.8.0 have the problem that my
> AggregationStrategy is ignored, when using .transacted() in the
> routedefinition.
> The breakpoint in the AggregationStrategy doesn't trigger. After removing
> transacted from the routedefinition everything is fine and the
> AggregationStrategy is used and the breakpoint triggers.
>
> Reproducer:
> [https://github.com/razilein/cameltest]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
