You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2021/12/20 14:34:20 UTC
[rocketmq] branch develop updated: [ISSUE #2383] Export putMessageFailedTimes with broker status (#2385)
This is an automated email from the ASF dual-hosted git repository.
yuzhou 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 f620a50 [ISSUE #2383] Export putMessageFailedTimes with broker status (#2385)
f620a50 is described below
commit f620a50bc7a556844501e9474dae6c603e454cfa
Author: 张旭 <ma...@gmail.com>
AuthorDate: Mon Dec 20 22:34:08 2021 +0800
[ISSUE #2383] Export putMessageFailedTimes with broker status (#2385)
Co-authored-by: zhangxu16 <zh...@xiaomi.com>
---
store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java b/store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java
index e8e7e04..2b78f27 100644
--- a/store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java
+++ b/store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java
@@ -177,6 +177,7 @@ public class StoreStatsService extends ServiceThread {
sb.append("\truntime: " + this.getFormatRuntime() + "\r\n");
sb.append("\tputMessageEntireTimeMax: " + this.putMessageEntireTimeMax + "\r\n");
sb.append("\tputMessageTimesTotal: " + totalTimes + "\r\n");
+ sb.append("\tgetPutMessageFailedTimes: " + this.getPutMessageFailedTimes() + "\r\n");
sb.append("\tputMessageSizeTotal: " + this.getPutMessageSizeTotal() + "\r\n");
sb.append("\tputMessageDistributeTime: " + this.getPutMessageDistributeTimeStringInfo(totalTimes)
+ "\r\n");
@@ -429,6 +430,7 @@ public class StoreStatsService extends ServiceThread {
result.put("runtime", this.getFormatRuntime());
result.put("putMessageEntireTimeMax", String.valueOf(this.putMessageEntireTimeMax));
result.put("putMessageTimesTotal", String.valueOf(totalTimes));
+ result.put("putMessageFailedTimes", String.valueOf(this.putMessageFailedTimes));
result.put("putMessageSizeTotal", String.valueOf(this.getPutMessageSizeTotal()));
result.put("putMessageDistributeTime",
String.valueOf(this.getPutMessageDistributeTimeStringInfo(totalTimes)));