camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Andy Fedotov (JIRA)" <j...@apache.org>
Subject [jira] [Created] (CAMEL-8955) Processor for .pollEnrich incorrectly handles provided AggregationStrategy
Date Sun, 12 Jul 2015 11:56:05 GMT
Andy Fedotov created CAMEL-8955:
-----------------------------------

             Summary: Processor for .pollEnrich incorrectly handles provided AggregationStrategy
                 Key: CAMEL-8955
                 URL: https://issues.apache.org/jira/browse/CAMEL-8955
             Project: Camel
          Issue Type: Bug
          Components: camel-core
    Affects Versions: 2.14.3
            Reporter: Andy Fedotov
            Priority: Minor


As it can be concluded from AggregationStrategy javadoc, and also from available implementations
such as GroupedExchangeAggregationStrategy, it should be used in the following manner:

{code:java}
AggregationStrategy strategy = new GroupedExchangeAggregationStrategy();

Exchange result = null;
result = strategy.aggregate(result, exchange1);
result = strategy.aggregate(result, exchange2);
// ... and so on
return result;
{code}

But PollEnricher do it in following manner:

{code:java}
AggregationStrategy strategy = new GroupedExchangeAggregationStrategy();

Exchange result = strategy.aggregate(exchange1, exchange2);
return result;
{code}

This leads to incorrect result returned after aggregation and lost exchanges.

Also PollEnricher doesn't handle CompletionAwareAggregationStrategy and does not call onCompletion().
Consequently GroupedExchangeAggregationStrategy does not return aggregated result in the Exchange
body.




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message