end if msg null

Bughue · Dec 4, 2024 · 8622d8d · 8622d8d
1 parent e0cd8a3
commit 8622d8d
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -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()));
     }