feat: 添加发送 TxMsg 前校验参数的方法

cadecode · cadecode · commit 8ef8baa7accf · 2023-08-20T20:48:08.000+08:00
diff --git a/common/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/handler/AbstractTxMsgHandler.java b/common/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/handler/AbstractTxMsgHandler.java
@@ -19,6 +19,8 @@ public abstract class AbstractTxMsgHandler {
 
     public abstract void doClear(Long autoClearInterval);
 
+    public abstract void checkBeforeSend(BaseTxMsg txMsg, MsgOption msgOption);
+
     public abstract void sendNoTransaction(BaseTxMsg txMsg, MsgOption msgOption);
 
     public abstract void sendNotCommit(BaseTxMsg txMsg, MsgOption msgOption);
diff --git a/common/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/util/TxMsgKit.java b/common/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/util/TxMsgKit.java
@@ -30,6 +30,7 @@ public void sendTx(BaseTxMsg txMsg) {
     }
 
     public void sendTx(BaseTxMsg txMsg, MsgOption msgOption) {
+        txMsgTaskHandler.checkBeforeSend(txMsg, msgOption);
         MsgOption currOption = txMsgProperties.createMsgOption(msgOption);
         // 若没有事务
         if (!TransactionSynchronizationManager.isActualTransactionActive()) {

Original file line number	Diff line number	Diff line change
`@@ -30,6 +30,7 @@ public void sendTx(BaseTxMsg txMsg) {`
`30`	`30`	`}`
`31`	`31`
`32`	`32`	`public void sendTx(BaseTxMsg txMsg, MsgOption msgOption) {`
	`33`	`+ txMsgTaskHandler.checkBeforeSend(txMsg, msgOption);`
`33`	`34`	`MsgOption currOption = txMsgProperties.createMsgOption(msgOption);`
`34`	`35`	`// 若没有事务`
`35`	`36`	`if (!TransactionSynchronizationManager.isActualTransactionActive()) {`