test/Raincat
1
0
Fork 0
mirror of https://gitee.com/dromara/Raincat.git synced 2024-12-02 03:48:35 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

解决嵌套事务里事务组group Id传递问题

Browse Source
This commit is contained in:
chaoshen 2018-06-11 17:20:21 +08:00
parent 9013bbb48b
commit 0c730f7add
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
raincat-core/src/main/java/com/raincat/core/service/handler/ActorTxTransactionHandler.java
View File

@ -28,6 +28,7 @@ import com.raincat.common.bean.TxTransactionInfo;
import com.raincat.core.compensation.command.TxCompensationCommand;
import com.raincat.core.concurrent.task.BlockTask;
import com.raincat.core.concurrent.task.BlockTaskHelper;
import com.raincat.core.concurrent.threadlocal.TxTransactionLocal;
import com.raincat.core.concurrent.threadpool.TransactionThreadPool;
import com.raincat.core.service.TxManagerMessageService;
import com.raincat.core.service.TxTransactionHandler;
@ -77,10 +78,12 @@ public class ActorTxTransactionHandler implements TxTransactionHandler {
LogUtil.info(LOGGER, "分布式事务参与方，开始执行,事务组id：{}", info::getTxGroupId);
final String taskKey = IdWorkerUtils.getInstance().createTaskKey();
final BlockTask task = BlockTaskHelper.getInstance().getTask(taskKey);
TxTransactionLocal.getInstance().setTxGroupId(info.getTxGroupId());
transactionThreadPool
.newFixedThreadPool()
.execute(() -> {
TxTransactionLocal.getInstance().setTxGroupId(info.getTxGroupId());
final String waitKey = IdWorkerUtils.getInstance().createTaskKey();
final BlockTask waitTask = BlockTaskHelper.getInstance().getTask(waitKey);
DefaultTransactionDefinition def = new DefaultTransactionDefinition();