If I use it below by removing threads() it is taking the messsages one by
one even though there are concurrent consumers.
from("jms-cif:queue:" +
_notificationQueue+"?concurrentConsumers="+concurrentConsumersSize).
process(processor)
.onException(Exception.class).retryUntil(bean("myRetryBean")).end()
.recipientList(header("recipientListHeader").tokenize(","))
.parallelProcessing().executorService(customThreadPoolExecutor)
.aggregationStrategy(new
RecipientAggregationStrategy(deliveryEndpoints, _endpointDeliveredBaseUri))
.to("direct:chunk.completed");
--
View this message in context:
http://old.nabble.com/Getting-exception-when-using-retryUntil-with-concurrentConsumers-tp28756173p28765667.html
Sent from the Camel - Users mailing list archive at Nabble.com.
