Add check to avoid npe

a8606d41 · zhangxu16 · d510dd79 · a8606d41
隐藏空白更改
内联并排

Showing with 3 addition and 0 deletion

store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java ...pache/rocketmq/store/schedule/ScheduleMessageService.java +3 -0

未找到文件。
--- a/store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java
+++ b/store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java
@@ -325,6 +325,9 @@ public class ScheduleMessageService extends ConfigManager {

                                        if (putMessageResult != null
                                            && putMessageResult.getPutMessageStatus() == PutMessageStatus.PUT_OK) {
+                                            if (ScheduleMessageService.this.brokerStatsManager == null) {
+                                                continue;
+                                            }
                                            ScheduleMessageService.this.brokerStatsManager.incTopicPutNums(msgInner.getTopic(), putMessageResult.getAppendMessageResult().getMsgNum(), 1);
                                            ScheduleMessageService.this.brokerStatsManager.incTopicPutSize(msgInner.getTopic(),
                                                putMessageResult.getAppendMessageResult().getWroteBytes());