提交 37cbf9f8 编写于 作者: Z zhenghu

[#1568] rocketmq need enhance stability when commitlog broken

 增加非空判断,防止空指针异常,导致循环事务 check
上级 2c414fa5
...@@ -176,7 +176,9 @@ public class TransactionalMessageBridge { ...@@ -176,7 +176,9 @@ 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);
foundList.add(msgExt); if(msgExt != null){
foundList.add(msgExt);
}
} }
} finally { } finally {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册