diff --git a/broker/src/test/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridgeTest.java b/broker/src/test/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridgeTest.java index f2636b7b1434979632ded12fa3788914d227fe83..ebe887285f0ff63fd81c741523a6f1820017fccc 100644 --- a/broker/src/test/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridgeTest.java +++ b/broker/src/test/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridgeTest.java @@ -182,7 +182,7 @@ public class TransactionalMessageBridgeTest { .getMessage(anyString(), anyString(), anyInt(), anyLong(), anyInt(), ArgumentMatchers.nullable(MessageFilter.class))) .thenReturn(null); PullResult result = transactionBridge.getHalfMessage(0, 0, 1); - assertThat(result.getPullStatus()).isNull(); + assertThat(result).isNull(); } private GetMessageResult createGetMessageResult(GetMessageStatus status) {