Permalink
Browse files

Adding cluster name to ProbeHandler in MessageDispatcher

  • Loading branch information...
1 parent b67eec5 commit b9c59ea518f1651c0a05a9dcceb417dbbcecd306 Bela Ban committed Apr 27, 2012
Showing with 7 additions and 6 deletions.
  1. +7 −6 src/org/jgroups/blocks/MessageDispatcher.java
@@ -481,12 +481,13 @@ public void channelClosed(Channel channel) {
Map<String,String> retval=new HashMap<String,String>();
for(String key: keys) {
if("rpcs".equals(key)) {
- retval.put("sync unicast RPCs", sync_unicasts.toString());
- retval.put("sync multicast RPCs", sync_multicasts.toString());
- retval.put("async unicast RPCs", async_unicasts.toString());
- retval.put("async multicast RPCs", async_multicasts.toString());
- retval.put("sync anycast RPCs", sync_anycasts.toString());
- retval.put("async anycast RPCs", async_anycasts.toString());
+ String channel_name = channel != null ? channel.getClusterName() : "";
+ retval.put(channel_name + ": sync unicast RPCs", sync_unicasts.toString());
+ retval.put(channel_name + ": sync multicast RPCs", sync_multicasts.toString());
+ retval.put(channel_name + ": async unicast RPCs", async_unicasts.toString());
+ retval.put(channel_name + ": async multicast RPCs", async_multicasts.toString());
+ retval.put(channel_name + ": sync anycast RPCs", sync_anycasts.toString());
+ retval.put(channel_name + ": async anycast RPCs", async_anycasts.toString());
}
if("rpcs-reset".equals(key)) {
sync_unicasts.set(0);

0 comments on commit b9c59ea

Please sign in to comment.