支付事务手动提交测试
This commit is contained in:
@@ -40,6 +40,7 @@ import org.springframework.http.ResponseEntity;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.transaction.PlatformTransactionManager;
|
||||
import org.springframework.transaction.TransactionDefinition;
|
||||
import org.springframework.transaction.TransactionManager;
|
||||
import org.springframework.transaction.TransactionStatus;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
import org.springframework.transaction.support.DefaultTransactionDefinition;
|
||||
@@ -130,6 +131,8 @@ public class PayService {
|
||||
private RabbitMsgUtils rabbitMsgUtils;
|
||||
@Autowired
|
||||
private TransactionTemplate transactionTemplate;
|
||||
@Autowired
|
||||
private PlatformTransactionManager transactionManager;
|
||||
|
||||
private final Utils utils;
|
||||
|
||||
@@ -1023,6 +1026,7 @@ public class PayService {
|
||||
// 提交当前事务
|
||||
transactionTemplate.execute((TransactionCallback<Void>) status -> {
|
||||
status.flush(); // 提交
|
||||
transactionManager.commit(status);
|
||||
return null;
|
||||
});
|
||||
log.info("已经手动提交事务");
|
||||
|
||||
Reference in New Issue
Block a user