opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #2383] Export putMessageFailedTimes with broker status (#2385)

Browse Source 
Co-authored-by: zhangxu16 <zhangxu16@xiaomi.com>
This commit is contained in:
张旭
2021-12-20 22:34:08 +08:00
committed by GitHub
co-authored by zhangxu16
parent 86c1216957
commit f620a50bc7
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java
+2
View File
@@ -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)));