io.jboot.support.seata.tcc

类 JbootTCCResourceManager

java.lang.Object

io.seata.rm.AbstractResourceManager

io.jboot.support.seata.tcc.JbootTCCResourceManager

所有已实现的接口:

io.seata.core.model.ResourceManager, io.seata.core.model.ResourceManagerInbound, io.seata.core.model.ResourceManagerOutbound

public class JbootTCCResourceManager
extends io.seata.rm.AbstractResourceManager

作者:

zhangxn

字段概要

字段

限定符和类型	字段和说明
private Map<String,io.seata.core.model.Resource>	tccResourceCache TCC resource cache

从类继承的字段 io.seata.rm.AbstractResourceManager

LOGGER

构造器概要

构造器

构造器和说明
JbootTCCResourceManager() Instantiates a new Tcc resource manager.

方法概要

限定符和类型	方法和说明
io.seata.core.model.BranchStatus	branchCommit(io.seata.core.model.BranchType branchType, String xid, long branchId, String resourceId, String applicationData) TCC branch commit
io.seata.core.model.BranchStatus	branchRollback(io.seata.core.model.BranchType branchType, String xid, long branchId, String resourceId, String applicationData) TCC branch rollback
io.seata.core.model.BranchType	getBranchType()
protected io.seata.rm.tcc.api.BusinessActionContext	getBusinessActionContext(String xid, long branchId, String resourceId, String applicationData) transfer tcc applicationData to BusinessActionContext
Map<String,io.seata.core.model.Resource>	getManagedResources()
private Object[]	getTwoPhaseCommitArgs(io.seata.rm.tcc.TCCResource tccResource, io.seata.rm.tcc.api.BusinessActionContext businessActionContext) get phase two commit method's args
private Object[]	getTwoPhaseMethodParams(String[] keys, Class<?>[] argsClasses, io.seata.rm.tcc.api.BusinessActionContext businessActionContext)
private Object[]	getTwoPhaseRollbackArgs(io.seata.rm.tcc.TCCResource tccResource, io.seata.rm.tcc.api.BusinessActionContext businessActionContext) get phase two rollback method's args
void	registerResource(io.seata.core.model.Resource resource) registry TCC resource

从类继承的方法 io.seata.rm.AbstractResourceManager

branchRegister, branchReport, lockQuery, unregisterResource

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

tccResourceCache

private Map<String,io.seata.core.model.Resource> tccResourceCache

TCC resource cache

构造器详细资料

JbootTCCResourceManager

public JbootTCCResourceManager()

Instantiates a new Tcc resource manager.

方法详细资料

registerResource

public void registerResource(io.seata.core.model.Resource resource)

registry TCC resource

指定者:

registerResource 在接口中 io.seata.core.model.ResourceManager

覆盖:

registerResource 在类中 io.seata.rm.AbstractResourceManager

参数:

resource - The resource to be managed.

getManagedResources

public Map<String,io.seata.core.model.Resource> getManagedResources()

branchCommit

public io.seata.core.model.BranchStatus branchCommit(io.seata.core.model.BranchType branchType,
                                                     String xid,
                                                     long branchId,
                                                     String resourceId,
                                                     String applicationData)
                                              throws io.seata.core.exception.TransactionException

TCC branch commit

参数:

branchType -

xid - Transaction id.

branchId - Branch id.

resourceId - Resource id.

applicationData - Application data bind with this branch.

返回:

BranchStatus

抛出:

io.seata.core.exception.TransactionException - TransactionException

branchRollback

public io.seata.core.model.BranchStatus branchRollback(io.seata.core.model.BranchType branchType,
                                                       String xid,
                                                       long branchId,
                                                       String resourceId,
                                                       String applicationData)
                                                throws io.seata.core.exception.TransactionException

TCC branch rollback

参数:

branchType - the branch type

xid - Transaction id.

branchId - Branch id.

resourceId - Resource id.

applicationData - Application data bind with this branch.

返回:

BranchStatus

抛出:

io.seata.core.exception.TransactionException - TransactionException

getBusinessActionContext

protected io.seata.rm.tcc.api.BusinessActionContext getBusinessActionContext(String xid,
                                                                             long branchId,
                                                                             String resourceId,
                                                                             String applicationData)

transfer tcc applicationData to BusinessActionContext

参数:

xid - the xid

branchId - the branch id

resourceId - the resource id

applicationData - the application data

返回:

business action context

getTwoPhaseCommitArgs

private Object[] getTwoPhaseCommitArgs(io.seata.rm.tcc.TCCResource tccResource,
                                       io.seata.rm.tcc.api.BusinessActionContext businessActionContext)

get phase two commit method's args

参数:

tccResource - tccResource

businessActionContext - businessActionContext

返回:

args

getTwoPhaseRollbackArgs

private Object[] getTwoPhaseRollbackArgs(io.seata.rm.tcc.TCCResource tccResource,
                                         io.seata.rm.tcc.api.BusinessActionContext businessActionContext)

get phase two rollback method's args

参数:

tccResource - tccResource

businessActionContext - businessActionContext

返回:

args

getTwoPhaseMethodParams

private Object[] getTwoPhaseMethodParams(String[] keys,
                                         Class<?>[] argsClasses,
                                         io.seata.rm.tcc.api.BusinessActionContext businessActionContext)

getBranchType

public io.seata.core.model.BranchType getBranchType()