Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #3505

This commit is contained in:
Clebert Suconic 2021-03-22 22:20:15 -04:00
parent 31345c5b51 4473758edb
commit 7c5ef2796a
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
artemis-server/src/main/java/org/apache/activemq/artemis/core/management/impl/ActiveMQServerControlImpl.java
View File

@ -4043,19 +4043,19 @@ public class ActiveMQServerControlImpl extends AbstractControl implements Active
Collection<TopologyMemberImpl> members = topology.getMembers(); Collection<TopologyMemberImpl> members = topology.getMembers();
for (TopologyMemberImpl member : members) { for (TopologyMemberImpl member : members) {
JsonObjectBuilder obj = JsonLoader.createObjectBuilder();
TransportConfiguration live = member.getLive(); TransportConfiguration live = member.getLive();
if (live != null) { if (live != null) {
JsonObjectBuilder obj = JsonLoader.createObjectBuilder();
obj.add("nodeID", member.getNodeId()).add("live", live.getParams().get("host") + ":" + live.getParams().get("port")); obj.add("nodeID", member.getNodeId()).add("live", live.getParams().get("host") + ":" + live.getParams().get("port"));
TransportConfiguration backup = member.getBackup(); TransportConfiguration backup = member.getBackup();
if (backup != null) { if (backup != null) {
obj.add("backup", backup.getParams().get("host") + ":" + backup.getParams().get("port")); obj.add("backup", backup.getParams().get("host") + ":" + backup.getParams().get("port"));
} }
}
brokers.add(obj); brokers.add(obj);
} }
} }
} }
}
return brokers.build().toString(); return brokers.build().toString();
} finally { } finally {
blockOnIO(); blockOnIO();