提交 159d28d5 编写于 作者: Z zhenghu

[#1568] rocketmq need enhance stability when commitlog broken

 增加非空判断,防止空指针异常,导致循环事务 check,增加test覆盖,修复编码格式
上级 d2345731
...@@ -131,7 +131,7 @@ public class TransactionalMessageBridge { ...@@ -131,7 +131,7 @@ public class TransactionalMessageBridge {
this.brokerController.getBrokerStatsManager().incGroupGetSize(group, topic, this.brokerController.getBrokerStatsManager().incGroupGetSize(group, topic,
getMessageResult.getBufferTotalSize()); getMessageResult.getBufferTotalSize());
this.brokerController.getBrokerStatsManager().incBrokerGetNums(getMessageResult.getMessageCount()); this.brokerController.getBrokerStatsManager().incBrokerGetNums(getMessageResult.getMessageCount());
if ( foundList == null || foundList.size() == 0 ) { if (foundList == null || foundList.size() == 0) {
break; break;
} }
this.brokerController.getBrokerStatsManager().recordDiskFallBehindTime(group, topic, queueId, this.brokerController.getBrokerStatsManager().recordDiskFallBehindTime(group, topic, queueId,
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册