[jira] [Created] (CAMEL-6557) AbstractListAggregationStrategy does not work with batch completion strategy

["David Arthur (JIRA)" <ji...@apache.org>]

David Arthur created CAMEL-6557:
-----------------------------------

             Summary: AbstractListAggregationStrategy does not work with batch completion strategy
                 Key: CAMEL-6557
                 URL: https://issues.apache.org/jira/browse/CAMEL-6557
             Project: Camel
          Issue Type: Bug
          Components: camel-core
    Affects Versions: 2.11.1
            Reporter: David Arthur


When my aggregator extends AbstractListAggregationStrategy, I never get aggregator completions from the batch consumer.

If I change my aggregator to be something like:

{code}
    Foo foo = newExchange.getIn().getBody(Foo.class);
    List<Foo> list = null;
    Exchange outExchange;
    if (oldExchange == null) {
      list = new LinkedList<Foo>();
      list.add(foo);
      newExchange.getIn().setBody(list);
      outExchange = newExchange;
    } else {
      list = oldExchange.getIn().getBody(List.class);
      list.add(foo);
      outExchange = oldExchange;
    }
    return outExchange;
{code}

then it works fine.

I'm guessing this is has something to do with AbstractListAggregationStrategy messing with properties or wrapping the actual exchanges (since the batch completion is triggered based on Exchange.BATCH_SIZE property)

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira