From cae19aa44f36775d8f95256e63e0cb50a0c0ba9f Mon Sep 17 00:00:00 2001
From: Neha Narkhede <neha.narkhede@gmail.com>
Date: Tue, 30 Apr 2013 15:35:01 -0700
Subject: [PATCH] KAFKA-889 Add mbeans to track socket server's response queue
 size in addition to request queue size; reviewed by Jun Rao and Joel Koshy

---
 core/src/main/scala/kafka/network/RequestChannel.scala | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/core/src/main/scala/kafka/network/RequestChannel.scala b/core/src/main/scala/kafka/network/RequestChannel.scala
index c0e0dfce960..c8f81c00cdf 100644
--- a/core/src/main/scala/kafka/network/RequestChannel.scala
+++ b/core/src/main/scala/kafka/network/RequestChannel.scala
@@ -103,6 +103,15 @@ class RequestChannel(val numProcessors: Int, val queueSize: Int) extends KafkaMe
     }
   )
 
+  for(i <- 0 until numProcessors) {
+    newGauge(
+      "Processor-" + i + "-ResponseQueueSize",
+      new Gauge[Int] {
+        def value = responseQueues(i).size()
+      }
+    )
+  }
+
   /** Send a request to be handled, potentially blocking until there is room in the queue for the request */
   def sendRequest(request: RequestChannel.Request) {
     requestQueue.put(request)