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 >
