Skip to content

Commit bee9df9

Browse files
committed
WIP refactoring jmx
1 parent 9d22b41 commit bee9df9

File tree

2 files changed

+19
-73
lines changed

2 files changed

+19
-73
lines changed

cluster/src/main/java/io/scalecube/cluster/ClusterImpl.java

Lines changed: 8 additions & 43 deletions
Original file line numberDiff line numberDiff line change
@@ -484,21 +484,11 @@ public boolean isShutdown() {
484484
@SuppressWarnings("unused")
485485
public interface MonitorMBean {
486486

487-
Collection<String> getId();
487+
int getClusterSize();
488488

489-
String getIdAsString();
489+
String getMember();
490490

491-
Collection<String> getAlias();
492-
493-
String getAliasAsString();
494-
495-
Collection<String> getAddress();
496-
497-
String getAddressAsString();
498-
499-
Collection<String> getMetadata();
500-
501-
String getMetadataAsString();
491+
String getMetadata();
502492
}
503493

504494
public static class JmxMonitorMBean extends AbstractMonitorMBean implements MonitorMBean {
@@ -510,42 +500,17 @@ private JmxMonitorMBean(ClusterImpl cluster) {
510500
}
511501

512502
@Override
513-
public Collection<String> getId() {
514-
return Collections.singleton(getIdAsString());
515-
}
516-
517-
@Override
518-
public String getIdAsString() {
519-
return cluster.member().id();
520-
}
521-
522-
@Override
523-
public Collection<String> getAlias() {
524-
return Collections.singleton(getAliasAsString());
525-
}
526-
527-
@Override
528-
public String getAliasAsString() {
529-
return cluster.member().alias();
530-
}
531-
532-
@Override
533-
public Collection<String> getAddress() {
534-
return Collections.singleton(getAddressAsString());
535-
}
536-
537-
@Override
538-
public String getAddressAsString() {
539-
return String.valueOf(cluster.member().address());
503+
public int getClusterSize() {
504+
return cluster.otherMembers().size() + 1;
540505
}
541506

542507
@Override
543-
public Collection<String> getMetadata() {
544-
return Collections.singletonList(getMetadataAsString());
508+
public String getMember() {
509+
return cluster.member().toString();
545510
}
546511

547512
@Override
548-
public String getMetadataAsString() {
513+
public String getMetadata() {
549514
return String.valueOf(cluster.metadataStore.metadata().map(Object::toString).orElse(null));
550515
}
551516

cluster/src/main/java/io/scalecube/cluster/membership/MembershipProtocolImpl.java

Lines changed: 11 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -726,17 +726,11 @@ public interface MonitorMBean {
726726

727727
int getIncarnation();
728728

729-
List<String> getAliveMembers();
729+
String getAliveMembers();
730730

731-
String getAliveMembersAsString();
731+
String getSuspectedMembers();
732732

733-
List<String> getSuspectedMembers();
734-
735-
String getSuspectedMembersAsString();
736-
737-
List<String> getDeadMembers();
738-
739-
String getDeadMembersAsString();
733+
String getRemovedMembers();
740734
}
741735

742736
public static class JmxMonitorMBean extends AbstractMonitorMBean implements MonitorMBean {
@@ -770,35 +764,22 @@ public int getIncarnation() {
770764
}
771765

772766
@Override
773-
public List<String> getAliveMembers() {
774-
return findRecordsByCondition(MembershipRecord::isAlive);
767+
public String getAliveMembers() {
768+
return findRecordsByCondition(MembershipRecord::isAlive).stream()
769+
.collect(Collectors.joining(",", "[", "]"));
775770
}
776771

777772
@Override
778-
public String getAliveMembersAsString() {
779-
return getAliveMembers().stream().collect(Collectors.joining(",", "[", "]"));
773+
public String getSuspectedMembers() {
774+
return findRecordsByCondition(MembershipRecord::isSuspect).stream()
775+
.collect(Collectors.joining(",", "[", "]"));
780776
}
781777

782778
@Override
783-
public List<String> getSuspectedMembers() {
784-
return findRecordsByCondition(MembershipRecord::isSuspect);
785-
}
786-
787-
@Override
788-
public String getSuspectedMembersAsString() {
789-
return getSuspectedMembers().stream().collect(Collectors.joining(",", "[", "]"));
790-
}
791-
792-
@Override
793-
public List<String> getDeadMembers() {
779+
public String getRemovedMembers() {
794780
return removedMembersHistory.stream()
795781
.map(MembershipEvent::toString)
796-
.collect(Collectors.toList());
797-
}
798-
799-
@Override
800-
public String getDeadMembersAsString() {
801-
return getDeadMembers().stream().collect(Collectors.joining(",", "[", "]"));
782+
.collect(Collectors.joining(",", "[", "]"));
802783
}
803784

804785
private List<String> findRecordsByCondition(Predicate<MembershipRecord> condition) {

0 commit comments

Comments
 (0)