Hello All,
I am using camel 12.2 and have seen some buildup with the seda queue. I'm
attempting to evaluate using the disruptor. It's a single pub sub config. I'm
trying to print the number of exchanges to be processed, which is 41.
<camel:log message="Queue Size:
${camelContext.getEndpoint('disruptor:PublishMarketData').getPendingExchangeCount}
Publish [{{jms.topic}}] ${body}" />
Although the msgs are being processed, the number returned from the bold text
is always 41. It doesn't update. Any ideas?
12:09:49,388 [Camel (camel-1) thread #0 - disruptor://PublishMarketData] INFO
JMSPublish - Queue Size: 41 Publish
12:09:49,638 [Camel (camel-1) thread #0 - disruptor://PublishMarketData] INFO
JMSPublish - Queue Size: 41 Publish
12:09:49,888 [Camel (camel-1) thread #0 - disruptor://PublishMarketData] INFO
JMSPublish - Queue Size: 41 Publish
Thanks
Geoff G
===============================================================================
Please access the attached hyperlink for an important electronic communications
disclaimer:
http://www.credit-suisse.com/legal/en/disclaimer_email_ib.html
===============================================================================
