AggregatinStrategy on split never stop

[Scisci]

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.