提交 903783f9 编写于 作者: Z zhenghu

[#1568] rocketmq need enhance stability when commitlog broken ...

[#1568] rocketmq need enhance stability when commitlog broken  增加非空判断,防止空指针异常,导致循环事务 check,增加test覆盖,修复编码格式
上级 9b9d2bd7
...@@ -182,7 +182,7 @@ public class TransactionalMessageBridgeTest { ...@@ -182,7 +182,7 @@ public class TransactionalMessageBridgeTest {
.getMessage(anyString(), anyString(), anyInt(), anyLong(), anyInt(), ArgumentMatchers.nullable(MessageFilter.class))) .getMessage(anyString(), anyString(), anyInt(), anyLong(), anyInt(), ArgumentMatchers.nullable(MessageFilter.class)))
.thenReturn(null); .thenReturn(null);
PullResult result = transactionBridge.getHalfMessage(0, 0, 1); PullResult result = transactionBridge.getHalfMessage(0, 0, 1);
assertThat(result.getPullStatus()).isNull(); assertThat(result).isNull();
} }
private GetMessageResult createGetMessageResult(GetMessageStatus status) { private GetMessageResult createGetMessageResult(GetMessageStatus status) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册