camel-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mathieuJ <mathieu.jam...@gmail.com>
Subject completionSize
Date Fri, 20 Apr 2012 09:01:19 GMT
Hi,

I have done a migration of Camel and i use completionTimeOut for my
aggregates.

But i would prefer used CompletionSize, with a dynamic size which is
register with a split before.

from(TARIF_LISTE_SIMULATION).routeId(TARIF_LISTE_SIMULATION)

	.bean(HeaderSetter.class, HeaderSetter.SET_ODEON_EXCHANGE_ID_HEADER)

       
.split(ExpressionBuilder.beanExpression(TarificationSimulationSpliter.class,
		                TarificationSimulationSpliter.SPLIT))
	
	.parallelProcessing()

	.bean(TarificationBean.class, TarificationBean.METHOD_NAME)
		        
       
.aggregate(DefaultAggregationStrategy.getInstance()).header(UsefulConstants.ODEONEXCHANGEID)
		        
        .bean(VoidProcessor.class).completionTimeout(30000)

        .end();

but i don't see how to use this and i looking for example.

regard's

Mathieu

--
View this message in context: http://camel.465427.n5.nabble.com/completionSize-tp5653718p5653718.html
Sent from the Camel Development mailing list archive at Nabble.com.

Mime
View raw message