Hi all,
I am using the Netty as the transport layer in Storm and have a few
questions:

1. My understanding is that there are two netty message queue per worker
process (one receive queue and one send queue per worker) and the
buffer_size configuration (storm.messaging.netty.buffer_size) controls the
size of the both. Is that right?
2. I can monitor the population of the internal message queues using a
metrics consumer. Is there a way to monitor the population of the netty
message queues?

Thanks,
-Serkan