oops, i posted too fast,
i missed the splitter int he route:
from("file:...).split(...)..streaming().parallelProcessing().inOut("bean:myProcessor").to("bean:checkHeaders").end().to("log:done");
- Romain
2011/5/25 Romain Manni-Bucau <rmannibu...@gmail.com>
> Hi,
>
> i have a route with a splitter with parallel processing + streaming.
>
> just after the split i run a processor in in-out mode setting some headers.
>
> Sometimes (i don't really know when) at the next step the headers i set in
> the processor are not in current exchange headers.
>
> If i replace my processor by setHeader() API (from the fluent API) + simple
> it works.
>
> What could it be?
>
> Here is the processor process method: exchange.getIn().setHeader("FOO",
> generator.next());
> Here is the route (in pseudo code):
> from("file:...).inOut("bean:myProcessor").to("bean:checkHeaders");
>
> - Romain
>
