It ends when there is no more data to split.
On Mon, Nov 16, 2015 at 9:14 AM, Scisci <ferioli.mi...@gmail.com> wrote:
> Hi,
> I've a problem with a split and custom aggregationStrateqy.
> I've to count the items that were split.
> This in my AggreagationSt egy
>
> public class Item_AggregationStrategy implements AggregationStrategy{
>
> private static final Logger LOGGER =
> Logger.getLogger(Item_AggregationStrategy.class);
>
>
> @Override
> public Exchange aggregate(Exchange oldExchange, Exchange newExchange)
> {
> LOGGER.info("Sono in Item_AggregationStrategy");
>
> if (oldExchange == null)
> {
> return newExchange;
> }
>
>
> Integer numero_items =
> oldExchange.getIn().getHeader("Numero_Items",
> Integer.class);
> LOGGER.info("Numero Items: " + numero_items);
> numero_items++;
> LOGGER.info("Numero Items 2: " + numero_items);
>
> newExchange.getIn().setHeader("Numero_Items", numero_items);
>
> return newExchange;
> }
>
> and this is part of my route:
>
> <process ref="Cancellazione_Tabelle"/>
> <split streaming="true"
> strategyRef="Item_Aggregator" >-->
> <tokenize token="Item" xml="true"
> inheritNamespaceTagName="ag_01:Accpos"/>
> <to uri="direct:Convert_Accpos"/>
> </split>
> <log message="Numero_Items dopo lo split:
> ${header.Numero_Items}"/>
>
> it's look like tha the aggregator never end...
> How to set a timeout like completionTimeout on aggregator ?
>
> Thanks
> Mirko
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/AggregatinStrategy-on-split-never-stop-tp5773905.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
--
Claus Ibsen
-----------------
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2
