[statistics] Add SendBack message to SCHEDULE_TOPIC_XXXX stats

Signed-off-by: zhangyang21 <zhangyang21@xiaomi.com>
apache · Sep 27, 2021 · f5229b4 · f5229b4
1 parent daf1b9d
commit f5229b4
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
@@ -238,6 +238,12 @@ private CompletableFuture<RemotingCommand> asyncConsumerSendMsgBack(ChannelHandl
                         if (correctTopic != null) {
                             backTopic = correctTopic;
                         }
+                        if (TopicValidator.RMQ_SYS_SCHEDULE_TOPIC.equals(msgInner.getTopic())) {
+                            this.brokerController.getBrokerStatsManager().incTopicPutNums(msgInner.getTopic());
+                            this.brokerController.getBrokerStatsManager().incTopicPutSize(msgInner.getTopic(), r.getAppendMessageResult().getWroteBytes());
+                            this.brokerController.getBrokerStatsManager().incQueuePutNums(msgInner.getTopic(), msgInner.getQueueId());
+                            this.brokerController.getBrokerStatsManager().incQueuePutSize(msgInner.getTopic(), msgInner.getQueueId(), r.getAppendMessageResult().getWroteBytes());
+                        }
                         this.brokerController.getBrokerStatsManager().incSendBackNums(requestHeader.getGroup(), backTopic);
                         response.setCode(ResponseCode.SUCCESS);
                         response.setRemark(null);