Hi all,
we have a route which is delivering of a given message to a list of
endpoints (HTTP, MAIL, FTP, JMS)
to achieve this we are using a recipentList (the endpoint list is dinamic)
once the delivery to a given endpoint is processed we need to update a
delivery trail through a web service, to achieve this we have introduced an
aggregationStrategy
this is the route (simplified):
from("direct:start")
.recipientList(header("recipientListHeader").tokenize(","))
.parallelProcessing().executorService(customThreadPoolExecutor)
.aggregationStrategy(new
RecipientAggregationStrategy()).to("direct:completed")
a list of new endpoint is processed as soon as the current one is not
completed, the problem is one of the endpoints might lag for a long time and
therefore the route gets stuck.
is there a way to set a timeout so that if not all endpoints are processed
after 30 secs the route runs in timeout and it starts processing the next?
--
View this message in context:
http://camel.465427.n5.nabble.com/recipientList-aggregationStrategy-timeout-tp2262937p2262937.html
Sent from the Camel - Users mailing list archive at Nabble.com.
