try this, https://github.com/verisign/storm-graphiteset up a graphite server on your local.register as metrics consumer. Thanking you. With Regards Sree
On Friday, March 3, 2017 12:00 AM, anshu shukla <anshushuk...@gmail.com> wrote: Thanks! On Fri, Mar 3, 2017 at 7:28 AM, Jungtaek Lim <kabh...@gmail.com> wrote: No you need to look at here: storm-core/src/jvm/org/apache/ storm/utils/DisruptorQueue. java It also has QueueMetrics for expose queue metrics to metrics consumers. Hope it helps. Thanks, Jungtaek Lim (HeartSaVioR) On Thu, 2 Mar 2017 at 9:02 PM anshu shukla <anshushuk...@gmail.com> wrote: Hello, I want to find the send and receive Queue size used by the LMAX Disruptor. But I am worried that while accessing the call hierarchy of the execute function in storm-starter code with StatefulSumBolt the end point to the Queue is : KeyedRoundRobinQueue<Tuple> _rrQueue; in package org.apache.storm.drpc; I am worrying is it the right place i should look in to ? I have attached the screenshot for that. -- Thanks & Regards, Anshu Shukla -- Thanks & Regards, Anshu Shukla