X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fjmx%2Fmbeans%2Fshardmanager%2FShardManagerInfo.java;h=5de46cb87b928ba53a85ad6fb8a2d5ec2bda2d37;hb=refs%2Fchanges%2F26%2F26426%2F2;hp=aaac644b558b3e1913facbd01bc5a07536bf30ee;hpb=a88392383dd0f836de1a8f70cfce85ef5d7fd91f;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/jmx/mbeans/shardmanager/ShardManagerInfo.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/jmx/mbeans/shardmanager/ShardManagerInfo.java index aaac644b55..5de46cb87b 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/jmx/mbeans/shardmanager/ShardManagerInfo.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/jmx/mbeans/shardmanager/ShardManagerInfo.java @@ -29,20 +29,22 @@ public class ShardManagerInfo extends AbstractMXBean implements ShardManagerInfo private static final Logger LOG = LoggerFactory.getLogger(ShardManagerInfo.class); + private final String memberName; private final List localShards; private boolean syncStatus = false; private ShardManager shardManager; - public ShardManagerInfo(String name, String mxBeanType, List localShards) { + public ShardManagerInfo(String memberName, String name, String mxBeanType, List localShards) { super(name, mxBeanType, JMX_CATEGORY_SHARD_MANAGER); + this.memberName = memberName; this.localShards = localShards; } - public static ShardManagerInfo createShardManagerMBean(String name, String mxBeanType, + public static ShardManagerInfo createShardManagerMBean(String memberName, String name, String mxBeanType, List localShards){ - ShardManagerInfo shardManagerInfo = new ShardManagerInfo(name, mxBeanType, localShards); + ShardManagerInfo shardManagerInfo = new ShardManagerInfo(memberName, name, mxBeanType, localShards); shardManagerInfo.registerMBean(); @@ -59,6 +61,11 @@ public class ShardManagerInfo extends AbstractMXBean implements ShardManagerInfo return this.syncStatus; } + @Override + public String getMemberName() { + return memberName; + } + @Override public void switchAllLocalShardsState(String newState, long term) { LOG.info("switchAllLocalShardsState called newState = {}, term = {}", newState, term);