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

StorageService: register the StreamManagerMBean

Browse Source 
This patch adds the registration of StreamManagerMBean to
StorageService, similiar to the way it is done in origin.

After this patch the StreamManager will be available via Jconsole.

Signed-off-by: Amnon Heiman <amnon@scylladb.com>
This commit is contained in:
Amnon Heiman 2015-11-03 11:08:28 +02:00
parent 3cb168bed3
commit 9b14550d0a
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/org/apache/cassandra/service/StorageService.java
View File

@ -38,6 +38,8 @@ import javax.ws.rs.core.MultivaluedMap;
import org.apache.cassandra.metrics.StorageMetrics; import org.apache.cassandra.metrics.StorageMetrics;
import org.apache.cassandra.repair.RepairParallelism; import org.apache.cassandra.repair.RepairParallelism;
import org.apache.cassandra.streaming.StreamManager;
import com.cloudius.urchin.api.APIClient; import com.cloudius.urchin.api.APIClient;
/** /**
@ -76,8 +78,7 @@ public class StorageService extends NotificationBroadcasterSupport
jmxObjectName = new ObjectName( jmxObjectName = new ObjectName(
"org.apache.cassandra.db:type=StorageService"); "org.apache.cassandra.db:type=StorageService");
mbs.registerMBean(this, jmxObjectName); mbs.registerMBean(this, jmxObjectName);
// mbs.registerMBean(StreamManager.instance, new ObjectName( mbs.registerMBean(StreamManager.getInstance(), new ObjectName(StreamManager.OBJECT_NAME));
// StreamManager.OBJECT_NAME));
} catch (Exception e) { } catch (Exception e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }