类 DmeDistributedTransactionalExecuteImpl
java.lang.Object
com.sie.mbm.mom.framework.db.executeDme.service.DmeDistributedTransactionalExecuteImpl
- 所有已实现的接口:
DmeTransactionalExecute
@Component
public class DmeDistributedTransactionalExecuteImpl
extends Object
implements DmeTransactionalExecute
参考:http://docs.dme.com/pages/58712b
-
字段概要
字段修饰符和类型字段说明private DmeTransactionalExecuteImplprivate MbmTransactionalExecuteImplprivate TransactionalTaskNoDelegator -
构造器概要
构造器 -
方法概要
修饰符和类型方法说明booleanbeginTransactional(DmeTransactional dmeTransactional) 开启分布式事务voidclearContext(DmeTransactional dmeTransactional) 清空事务的ThreadLocalContext 清空分布式事务的ThreadLocalContextbooleancommitTransactional(DmeTransactional dmeTransactional) 提交分布式事务获取分布式事务任务信息, 没有则返回空指针; 自动对任务no + 1private DmeTransactionalExecutegetExecuteInstance(DmeTransactional dmeTransactional) 获取执行器private booleanisCaller()判定当前是否是事务的调用者boolean判定当前是否是分布式事务上下文private void从分布式缓存更新taskNo到本地事务数据中booleanrollbackTransactional(DmeTransactional dmeTransactional, Exception exception) 回滚分布式事务
-
字段详细资料
-
dmeTransactionalExecuteImpl
-
mbmTransactionalExecuteImpl
-
transactionalTaskNoDelegator
-
-
构造器详细资料
-
DmeDistributedTransactionalExecuteImpl
public DmeDistributedTransactionalExecuteImpl()
-
-
方法详细资料
-
beginTransactional
开启分布式事务- 指定者:
beginTransactional在接口中DmeTransactionalExecute
-
commitTransactional
提交分布式事务- 指定者:
commitTransactional在接口中DmeTransactionalExecute
-
rollbackTransactional
回滚分布式事务- 指定者:
rollbackTransactional在接口中DmeTransactionalExecute
-
isDistributedTransactionContext
public boolean isDistributedTransactionContext()判定当前是否是分布式事务上下文 -
getAndIncreaseTransactionTaskId
获取分布式事务任务信息, 没有则返回空指针; 自动对任务no + 1- 指定者:
getAndIncreaseTransactionTaskId在接口中DmeTransactionalExecute- 返回:
- 任务id 和 任务号
-
clearContext
清空事务的ThreadLocalContext 清空分布式事务的ThreadLocalContext- 指定者:
clearContext在接口中DmeTransactionalExecute
-
isCaller
private boolean isCaller()判定当前是否是事务的调用者- 返回:
- 是: 事务的调用者 否: 不是
-
reloadTaskNo
private void reloadTaskNo()从分布式缓存更新taskNo到本地事务数据中 -
getExecuteInstance
获取执行器
-