You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2023/02/06 02:16:26 UTC
[rocketmq] branch develop updated: [ISSUE #5969] Remvoe duplicate deleteUnusedStats in admin processor (#5973)
This is an automated email from the ASF dual-hosted git repository.
lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new b6e0bf318 [ISSUE #5969] Remvoe duplicate deleteUnusedStats in admin processor (#5973)
b6e0bf318 is described below
commit b6e0bf318080eee8b38f690a56829108f457eb28
Author: zhiliatom <87...@users.noreply.github.com>
AuthorDate: Mon Feb 6 10:16:05 2023 +0800
[ISSUE #5969] Remvoe duplicate deleteUnusedStats in admin processor (#5973)
---
.../org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java | 4 ----
1 file changed, 4 deletions(-)
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
index 5df7902dc..78f50c92b 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
@@ -527,10 +527,6 @@ public class AdminBrokerProcessor implements NettyRequestProcessor {
this.brokerController.getConsumerOffsetManager().cleanOffsetByTopic(requestHeader.getTopic());
this.brokerController.getPopInflightMessageCounter().clearInFlightMessageNumByTopicName(requestHeader.getTopic());
this.brokerController.getMessageStore().deleteTopics(Sets.newHashSet(requestHeader.getTopic()));
- if (this.brokerController.getBrokerConfig().isAutoDeleteUnusedStats()) {
- this.brokerController.getBrokerStatsManager().onTopicDeleted(requestHeader.getTopic());
- }
-
response.setCode(ResponseCode.SUCCESS);
response.setRemark(null);
return response;