[ISSUE #3384] Add SendBack message to SCHEDULE_TOPIC_XXXX stats #3385

Signed-off-by: N zhangyang21 <zhangyang21@xiaomi.com>

[ISSUE #3384] Add SendBack message to SCHEDULE_TOPIC_XXXX stats #3385
Signed-off-by: N zhangyang21 <zhangyang21@xiaomi.com>
c6a4b822 · Git_Yang · GitHub · daf1b9df · c6a4b822
显示空白变更内容
内联并排

Showing with 6 addition and 0 deletion

broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java ...pache/rocketmq/broker/processor/SendMessageProcessor.java +6 -0

未找到文件。
--- 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 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement
                        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);