Hi,
I'm basically trying to achieve this:
from("file:input?move=output").loadBalance().to("direct:Q1","direct:Q2","direct:Q3")
from("direct:Q1").setHeader("queue",constant("Q1")).to("direct:processFile")
from("direct:Q2").setHeader("queue",constant("Q2")).to("direct:processFile")
from("direct:Q3").setHeader("queue",constant("Q3")).to("direct:processFile")
from("direct:processFile").split(body(),myConcatenateLinesStrategy).parallelProcessing()
.process(...)
[...]
.to("direct:processLine")
.end()
.process(myEndOfProcessingFileProcessor)
// Only Now move file to output
;
I think there is no point of having :
- parallelProcessing on the splitter since i'm using
to("direct:processLine") which runs one only thread
- loadBalance since they all point to the same direct
And if I use seda?concurrentConsumers=10 instead, the file is moved before
it's processed (UnitOfWork stops at to("seda:") I think) ...
>From what I get of thread(10) it wouldn't help either because the exchange
wouldn't get to the myEndOfProcessingFileProcessor part
Why is there no way to have direct?concurrentConsumers=10 ? Or Am I missing
something ?
Thanks a lot !
Wandrille
--
View this message in context:
http://old.nabble.com/Using-Concurrent-Consumers-within-a-splitter-tp27705170p27705170.html
Sent from the Camel - Users mailing list archive at Nabble.com.
