feat: TxMsgKit 添加没有事务的消息发送方法

Author: cadecode

common/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/util/TxMsgKit.java

@@ -25,10 +25,23 @@ public class TxMsgKit {
 
     private final AbstractTxMsgHandler txMsgTaskHandler;
 
+    /**
+     * 发送事务消息
+     * 需要事务
+     *
+     * @param txMsg 事务消息
+     */
     public void sendTx(BaseTxMsg txMsg) {
         sendTx(txMsg, null);
     }
 
+    /**
+     * 发送事务消息
+     * 需要事务
+     *
+     * @param txMsg 事务消息
+     * @param msgOption 消息配置
+     */
     public void sendTx(BaseTxMsg txMsg, MsgOption msgOption) {
         MsgOption currOption = txMsgProperties.createMsgOption(msgOption);
         txMsgTaskHandler.checkBeforeSend(txMsg, currOption);
@@ -54,4 +67,18 @@ public void afterCompletion(int status) {
             }
         });
     }
+
+    /**
+     * 发送事务消息
+     * 不检查是否存在事务
+     *
+     * @param txMsg 事务消息
+     * @param msgOption 消息配置
+     */
+    public void sendWithoutTx(BaseTxMsg txMsg, MsgOption msgOption) {
+        MsgOption currOption = txMsgProperties.createMsgOption(msgOption);
+        txMsgTaskHandler.checkBeforeSend(txMsg, currOption);
+        txMsgTaskHandler.saveBeforeRegister(txMsg, currOption);
+        txMsgTaskHandler.sendCommitted(txMsg, currOption);
+    }
 }