jiulinxiri/rocketmq-dashboard
1
0
Fork 0
mirror of https://github.com/apache/rocketmq-dashboard.git synced 2025-09-11 03:49:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #670] Fix building error

Browse Source
This commit is contained in:
elegance code
2021-01-12 20:08:48 +08:00
committed by GitHub
parent a615c8cc59
commit a6ce939388
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/apache/rocketmq/console/task/DashboardCollectTask.java
View File

@@ -327,7 +327,7 @@ public class DashboardCollectTask {
private void addSystemTopic() throws Exception { private void addSystemTopic() throws Exception {
ClusterInfo clusterInfo = mqAdminExt.examineBrokerClusterInfo(); ClusterInfo clusterInfo = mqAdminExt.examineBrokerClusterInfo();
HashMap<String, Set<String>> clusterTable = clusterInfo.getClusterAddrTable(); HashMap<String, Set<String>> clusterTable = clusterInfo.getClusterAddrTable();
for(Map.Entry<String, Set<String>> entry : clusterTable.entrySet()){ for (Map.Entry<String, Set<String>> entry : clusterTable.entrySet()) {
String clusterName = entry.getKey(); String clusterName = entry.getKey();
TopicValidator.addSystemTopic(clusterName); TopicValidator.addSystemTopic(clusterName);
Set<String> brokerNames = entry.getValue(); Set<String> brokerNames = entry.getValue();