Retrieving the number of exchanges "enque" in the Disruptor component

["Gershaw, Geoffrey A. " <ge...@credit-suisse.com>]

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 
===============================================================================