jiulinxiri/rocketmq-dashboard
1
0
Fork 0
mirror of https://github.com/apache/rocketmq-dashboard.git synced 2025-09-10 19:48:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: Solve the null pointer after a single refresh of the consumer #295 (#296)

Browse Source
This commit is contained in:
Crazylychee
2025-06-12 10:45:38 +08:00
committed by GitHub
parent a450594ace
commit c85aa2e2a9
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/org/apache/rocketmq/dashboard/service/impl/ConsumerServiceImpl.java
View File

@@ -103,6 +103,8 @@ public class ConsumerServiceImpl extends AbstractCommonService implements Consum
private final List<GroupConsumeInfo> cacheConsumeInfoList = Collections.synchronizedList(new ArrayList<>()); private final List<GroupConsumeInfo> cacheConsumeInfoList = Collections.synchronizedList(new ArrayList<>());
private final HashMap<String, List<String>> consumerGroupMap = Maps.newHashMap();
@Override @Override
public void afterPropertiesSet() { public void afterPropertiesSet() {
Runtime runtime = Runtime.getRuntime(); Runtime runtime = Runtime.getRuntime();
@@ -174,7 +176,6 @@ public class ConsumerServiceImpl extends AbstractCommonService implements Consum
public void makeGroupListCache() { public void makeGroupListCache() {
HashMap<String, List<String>> consumerGroupMap = Maps.newHashMap();
SubscriptionGroupWrapper subscriptionGroupWrapper = null; SubscriptionGroupWrapper subscriptionGroupWrapper = null;
try { try {
ClusterInfo clusterInfo = clusterInfoService.get(); ClusterInfo clusterInfo = clusterInfoService.get();
@@ -530,6 +531,7 @@ public class ConsumerServiceImpl extends AbstractCommonService implements Consum
GroupConsumeInfo updatedInfo = queryGroup(consumerGroup, ""); GroupConsumeInfo updatedInfo = queryGroup(consumerGroup, "");
updatedInfo.setUpdateTime(new Date()); updatedInfo.setUpdateTime(new Date());
updatedInfo.setGroup(consumerGroup); updatedInfo.setGroup(consumerGroup);
updatedInfo.setAddress(consumerGroupMap.get(consumerGroup));
cacheConsumeInfoList.set(i, updatedInfo); cacheConsumeInfoList.set(i, updatedInfo);
return updatedInfo; return updatedInfo;
} }
@@ -541,6 +543,7 @@ public class ConsumerServiceImpl extends AbstractCommonService implements Consum
@Override @Override
public List<GroupConsumeInfo> refreshAllGroup(String address) { public List<GroupConsumeInfo> refreshAllGroup(String address) {
cacheConsumeInfoList.clear(); cacheConsumeInfoList.clear();
consumerGroupMap.clear();
return queryGroupList(false, address); return queryGroupList(false, address);
} }
} }

2
src/main/java/org/apache/rocketmq/dashboard/service/impl/TopicServiceImpl.java
View File

@@ -91,8 +91,6 @@ public class TopicServiceImpl extends AbstractCommonService implements TopicServ
@Autowired @Autowired
private RMQConfigure configure; private RMQConfigure configure;
private final ConcurrentMap<String, TopicConfig> topicConfigCache = new ConcurrentHashMap<>();
@Override @Override
public TopicList fetchAllTopicList(boolean skipSysProcess, boolean skipRetryAndDlq) { public TopicList fetchAllTopicList(boolean skipSysProcess, boolean skipRetryAndDlq) {
try { try {