From 8622d8d49308a4944be2e94eeefa781dffa6d7ea Mon Sep 17 00:00:00 2001 From: "minghua.xie" Date: Wed, 4 Dec 2024 14:34:30 +0800 Subject: [PATCH] end if msg null --- .../org/apache/seata/integration/rocketmq/TCCRocketMQImpl.java | 1 + 1 file changed, 1 insertion(+) diff --git a/rocketmq/src/main/java/org/apache/seata/integration/rocketmq/TCCRocketMQImpl.java b/rocketmq/src/main/java/org/apache/seata/integration/rocketmq/TCCRocketMQImpl.java index bc72af8ce85..cc7ad102006 100644 --- a/rocketmq/src/main/java/org/apache/seata/integration/rocketmq/TCCRocketMQImpl.java +++ b/rocketmq/src/main/java/org/apache/seata/integration/rocketmq/TCCRocketMQImpl.java @@ -96,6 +96,7 @@ public boolean rollback(BusinessActionContext context) } private static boolean checkMqStatus(Message message, SendResult sendResult) { + LOGGER.info("checkMqStatus message = {}, sendResult = {}", message, sendResult); return message == null || sendResult == null || (StringUtils.isBlank(sendResult.getOffsetMsgId()) && StringUtils.isBlank(sendResult.getMsgId())); }