just have your parser output a List and use a splitter to queue them
separately...I think something like this is what you are looking for...
from("file:inbox")
.bean(MyFileParser)
.split()
.to("activemq:queue:myQueue");
then, you can do multi-threaded processing from that queue...
from("activemq:queue:myQueue?maxConcurrentConsumers=10")
.bean(MyProcessor)...
Joe White-3 wrote:
>
> I have a route setup with a file endpoint that processes large files and
> generates thousands of individual objects from those files. Right now i
> have a route with the parser first and then downstream processing on the
> batch of individual objects.
>
>
>
> I would like to be able to multicast the individual objects as they are
> generated to a set of queues configured in Spring. Is there a Camel way
> to do this without writing Java to have my parser publish each object to
> a queue and then multicasting from that intermediate queue? Seems like
> an extra step.
>
>
>
> Essentially I want my parser to generate a new exchange for every object
> generated from the file rather than one exchange for the whole file.
>
>
>
> Thanks
>
> Joe
>
-----
Ben O'Day
IT Consultant -http://consulting-notes.com
--
View this message in context:
http://camel.465427.n5.nabble.com/Complete-exchange-from-file-parsing-before-parsing-complete-tp4473282p4473919.html
Sent from the Camel - Users mailing list archive at Nabble.com.
