andreacavalli
/
scylla-jmx
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

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>
This commit is contained in:
Amnon Heiman 2015-11-03 11:06:18 +02:00
parent 20778b2df6
commit 3cb168bed3
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/apache/cassandra/net/MessagingService.java
View File

@ -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");
}
/**