camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Okello Nelson <cn.oke...@gmail.com>
Subject Block a Queue until all exchanges are received
Date Tue, 16 Apr 2013 08:49:41 GMT
Hi Guys,

Having a route DSL as:

from("file:" + classesBaseDir + "/" + fileType +
"/step0?preMove=inprogress&moveFailed=.error&move=.done&readLock=true")
.routeId(dirRepoPrefix + fileType + "-To-" + queuePrefix + fileType +
"_ParsingQ")
.threads(50)
.split().tokenize("\n", 5).streaming().parallelProcessing()
.doTry().to(queuePrefix + fileType + "_ParsingQ?asyncConsumer=true")
.doCatch(Exception.class).to(queuePrefix + fileType + "_InvalidParsingQ");

There's another route that consumes the exchanges of the "...ParsingQ".
However, I want exchanges at "...ParsingQ" to be consumed only when all the
files have been loaded into the queue. Is there a way I can implement this?

Thanks a lot in advance.

Kind Regards,
Okello Nelson.

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message