You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/01/02 14:18:58 UTC
[jira] [Commented] (CAMEL-10272) Unexpected behaviour in aggregator
if recipient list is processed in parallel
[ https://issues.apache.org/jira/browse/CAMEL-10272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15792936#comment-15792936 ]
ASF GitHub Bot commented on CAMEL-10272:
----------------------------------------
Github user aldettinger closed the pull request at:
https://github.com/apache/camel/pull/1367
> Unexpected behaviour in aggregator if recipient list is processed in parallel
> -----------------------------------------------------------------------------
>
> Key: CAMEL-10272
> URL: https://issues.apache.org/jira/browse/CAMEL-10272
> Project: Camel
> Issue Type: Bug
> Components: camel-core
> Affects Versions: 2.16.3, 2.17.3
> Environment: MacOS 10.11.6, JRE 1.7.0_79
> Reporter: Peter Keller
> Assignee: Claus Ibsen
> Fix For: 2.19.0
>
>
> h3. Problem
> The {{oldExchange}} is {{null}} more than once in the aggregator if a recipient list is processed in parallel.
> h3. Camel route
> In my Camel route, a recipient list is worked of in parallel:
> {code}
> from("direct:start")
> .to("direct:pre")
> .recipientList().method(new MyRecipientListBuilder())
> .stopOnException()
> .aggregationStrategy(new MyAggregationStrategy())
> .parallelProcessing()
> .end()
> .bean(new MyPostProcessor());
> {code}
> Snippet of {{MyAggregationStrategy}}:
> {code}
> @Override
> @SuppressWarnings("unchecked")
> public Exchange aggregate(final Exchange oldExchange, final Exchange newExchange) {
> if (oldExchange == null) {
> // this is the case more than once which is not expected!
> }
> // ...
> {code}
> {{oldExchange}} is null more than once which is not expected and which contradicts the contract with Camel.
> h3. Analysis
> Unfortunately, I am not able to provide a (simple) unit test for comprehending the problem. Furthermore our (complex) unit tests are not deterministic due to the root cause of the problem.
> During the processing, Camel invokes {{ParallelAggregateTask.doAggregateInternal()}}. If aggregation is not done in parallel (as it is the case in our route), this is supposed to be done synchronously:
> {code}
> protected void doAggregateInternal(AggregationStrategy strategy, AtomicExchange result, Exchange exchange) {
> if (strategy != null) {
> // prepare the exchanges for aggregation
> Exchange oldExchange = result.get();
> ExchangeHelper.prepareAggregation(oldExchange, exchange);
> result.set(strategy.aggregate(oldExchange, exchange));
> }
> }
> {code}
> However, is it possible that we face a race condition in {{doAggregateInternal}} even if this method is supposed to be invoked synchronously?
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)