From 3cb168bed3bc1d100edf46491d739e61d5abcae8 Mon Sep 17 00:00:00 2001
From: Amnon Heiman <amnon@scylladb.com>
Date: Tue, 3 Nov 2015 11:06:18 +0200
Subject: [PATCH] MessagingService: Add tasks statistics

This patch adds the implementation of:
getResponsePendingTasks()
getResponseCompletedTasks()
getDroppedMessages()

The implementation is based on the messaging_service API that defined in
messaging_service.json.

Signed-off-by: Amnon Heiman <amnon@scylladb.com>
---
 .../java/org/apache/cassandra/net/MessagingService.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main/java/org/apache/cassandra/net/MessagingService.java b/src/main/java/org/apache/cassandra/net/MessagingService.java
index 0278bf7..2389379 100644
--- a/src/main/java/org/apache/cassandra/net/MessagingService.java
+++ b/src/main/java/org/apache/cassandra/net/MessagingService.java
@@ -94,7 +94,7 @@ public final class MessagingService implements MessagingServiceMBean {
      */
     public Map<String, Integer> getResponsePendingTasks() {
         log(" getResponsePendingTasks()");
-        return c.getMapStringIntegerValue("");
+        return c.getMapStringIntegerValue("/messaging_service/messages/respond_pending");
     }
 
     /**
@@ -102,7 +102,7 @@ public final class MessagingService implements MessagingServiceMBean {
      */
     public Map<String, Long> getResponseCompletedTasks() {
         log(" getResponseCompletedTasks()");
-        return c.getMapStringLongValue("");
+        return c.getMapStringLongValue("/messaging_service/messages/respond_completed");
     }
 
     /**
@@ -110,7 +110,7 @@ public final class MessagingService implements MessagingServiceMBean {
      */
     public Map<String, Integer> getDroppedMessages() {
         log(" getDroppedMessages()");
-        return c.getMapStringIntegerValue("");
+        return c.getMapStringIntegerValue("/messaging_service/messages/dropped");
     }
 
     /**