end if msg null

Bughue · Dec 3, 2024 · a5395aa · a5395aa
1 parent 4b57746
commit a5395aa
Showing 1 changed file with 2 additions and 2 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
@@ -75,7 +75,7 @@ public boolean commit(BusinessActionContext context)
         Message message = context.getActionContext(ROCKET_MSG_KEY, Message.class);
         SendResult sendResult = context.getActionContext(ROCKET_SEND_RESULT_KEY, SendResult.class);
         if (checkMqStatus(message, sendResult)) {
-            throw new TransactionException("TCCRocketMQ commit but cannot find message and sendResult");
+            throw new TransactionException("TCCRocketMQ commit but cannot find message or sendResult");
         }
         this.producerImpl.endTransaction(message, sendResult, LocalTransactionState.COMMIT_MESSAGE, null);
         LOGGER.info("RocketMQ message send commit, xid = {}, branchId = {}", context.getXid(), context.getBranchId());
@@ -88,7 +88,7 @@ public boolean rollback(BusinessActionContext context)
         Message message = context.getActionContext(ROCKET_MSG_KEY, Message.class);
         SendResult sendResult = context.getActionContext(ROCKET_SEND_RESULT_KEY, SendResult.class);
         if (checkMqStatus(message, sendResult)) {
-            LOGGER.error("TCCRocketMQ rollback but cannot find message and sendResult");
+            LOGGER.error("TCCRocketMQ rollback but cannot find message or sendResult");
             return true;
         }
         this.producerImpl.endTransaction(message, sendResult, LocalTransactionState.ROLLBACK_MESSAGE, null);