Re: When original exchange "isDone" - with aggregator?

[Joakim Bjørnstad]

Hello,

On Mon, Oct 12, 2015 at 4:40 PM, dermoritz <tantea...@hotmail.com> wrote:
> My route looks like this
>
>         from( trigger )
>             .routePolicy( new FinishNotifier( onFinsh ) )
>             .to( in ).split().body()
>             .streaming()
>             .process( aggregationHeaderProcessor )
>             .aggregate( header( AggregationHeaderProcessor.ORDER_ID_HEADER
> ), packAggregator )
>             .completionSize( header(
> AggregationHeaderProcessor.PACK_COUNT_HEADER ) )
>             .executorService( Executors.newFixedThreadPool(
> validationThreads ) )
>             .log( LoggingLevel.TRACE, "Processing order #
> ${property.CamelSplitSize}" )
>             .process( validationProcessor )
>             .process( statusCounterProcessor )
>             .process( statisticsProcessor )
>             .process( validationResultProcessor )
>             .to( out )
>             .routeId( ROUTE_ID );
>
> FinishNotifier only implements "onExchangeDone". My problem is that this is
> called right after aggregation has completed. But i want that complete route
> has finished when exchange is done. The route worked fine without the 3
> lines for aggregation (process(), aggregate(), completionSize). So i suspect
> the aggregator to mark the exchange as done.
> So is there a way to unmark or prevent the too early call of
> onExchangeIsDone ?
>

I don't know any way of doing that. But instead, have you tried using
onCompletion instead of the RoutePolicy?

http://camel.apache.org/oncompletion.html

from("direct:start")
  .onCompletion()
  .process(exchange -> {
     // do something
  })
  .end()
  .to(in).split() ... etc

>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/When-original-exchange-isDone-with-aggregator-tp5772577.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Kind regards
Joakim Bjørnstad