Hello,
I am using concurrent consumers to process the messages from active mq and I
wanted to get the thread number to debug which thread is processing which
message. is there any way that I can get the thread number from the
processor.
I am using the route in the following way.
from("jms-test:queue:" + _notificationQueue
+
"?concurrentConsumers=" + concurrentConsumers)
.onException(Exception.class).retryWhile(
bean("myRetryBean")).end()
.threads(concurrentConsumers).process(processor)
.recipientList(
header("recipientListHeader").tokenize(","))
.parallelProcessing().timeout(aggregationTimeout)
.executorService(customThreadPoolExecutor).streaming()
.aggregationStrategy(
new
RecipientAggregationStrategy(
_endpointDeliveredBaseUri)).to(
"direct:chunk.completed");
suppose if the concurrent consumers size is 5 , there will be 5 threads
consuming messages with thread numbers starts from 0 to 5.
is there any way that I can get this number.
Thanks for your help in advance.
Regards
Sri
--
View this message in context:
http://camel.465427.n5.nabble.com/Getting-Thread-number-on-concurrent-consumers-threads-tp3208969p3208969.html
Sent from the Camel - Users mailing list archive at Nabble.com.
