Am 16.08.12 11:31 schrieb "Aleksander Pena" unter <aleksander.p...@gmail.com>:
>Hi Babak, > >your solution works fine but you removed parallel processing which is >important for me :) Just be aware that if you make use of parallelProcessing option then you've got no guarantee about the *order* of the outcomes. As an example try to run the following unit-test and see how the content of the file "target/concurrent/outbox/result.txt" seems like: https://svn.apache.org/repos/asf/camel/trunk/camel-core/src/test/java/org/a pache/camel/component/file/FileConcurrentWriteAppendSameFileTest.java And that even it's content could be different by each run of the test! >Anyway I found solution for my original problem: Happy to hear that. > >1. before processing is started I'm storing current exchange (from a main >thread) as a property (myEx). Then myEx property is propagated to splitter >threads. >2. after aggregation is ended (in splitter thread) I'm retrieving 'myEx' >exchange from properties and set new property on it with aggregation >results (myRes). >3. after whole processing (when I'm in the main thread again) I'm >retrieving myRes property from the exchange and set it as a body :) > >Thanks guys for all your help, >Alek > > > > >-- >View this message in context: >http://camel.465427.n5.nabble.com/Splitter-aggregator-dynamic-timeout-tp57 >17166p5717486.html >Sent from the Camel - Users mailing list archive at Nabble.com.
