Skip to content

Commit 65186d8

Browse files
committed
fix: 入参 msgOption 错误
1 parent 94ba2f3 commit 65186d8

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

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

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,16 +30,16 @@ public void sendTx(BaseTxMsg txMsg) {
3030
}
3131

3232
public void sendTx(BaseTxMsg txMsg, MsgOption msgOption) {
33-
txMsgTaskHandler.checkBeforeSend(txMsg, msgOption);
3433
MsgOption currOption = txMsgProperties.createMsgOption(msgOption);
34+
txMsgTaskHandler.checkBeforeSend(txMsg, currOption);
3535
// 若没有事务
3636
if (!TransactionSynchronizationManager.isActualTransactionActive()) {
3737
log.error("TxMsg send need transaction, txMsg:{}, biz:{}_{}", txMsg.getId(), txMsg.getBizType(), txMsg.getBizKey());
3838
txMsgTaskHandler.sendNoTransaction(txMsg, currOption);
3939
return;
4040
}
4141
// 持久化
42-
txMsgTaskHandler.saveBeforeRegister(txMsg, msgOption);
42+
txMsgTaskHandler.saveBeforeRegister(txMsg, currOption);
4343
// 注册到事务管理器
4444
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
4545
@Override

0 commit comments

Comments
 (0)