提交 e8a0fea4 编写于 作者: Z zhenghu

[#1568] rocketmq need enhance stability when commitlog broken

 增加非空判断,防止空指针异常,导致循环事务 check
上级 37cbf9f8
...@@ -176,7 +176,7 @@ public class TransactionalMessageBridge { ...@@ -176,7 +176,7 @@ public class TransactionalMessageBridge {
List<ByteBuffer> messageBufferList = getMessageResult.getMessageBufferList(); List<ByteBuffer> messageBufferList = getMessageResult.getMessageBufferList();
for (ByteBuffer bb : messageBufferList) { for (ByteBuffer bb : messageBufferList) {
MessageExt msgExt = MessageDecoder.decode(bb); MessageExt msgExt = MessageDecoder.decode(bb);
if(msgExt != null){ if (msgExt != null) {
foundList.add(msgExt); foundList.add(msgExt);
} }
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册