io.seata.rm

类 DefaultResourceManager

java.lang.Object

io.seata.rm.DefaultResourceManager

所有已实现的接口:

ResourceManager, ResourceManagerInbound, ResourceManagerOutbound

public class DefaultResourceManager
extends Object
implements ResourceManager

default resource manager, adapt all resource managers

作者:

zhangsen

字段概要

字段

限定符和类型	字段和说明
protected static Map<BranchType,ResourceManager>	resourceManagers all resource managers

方法概要

限定符和类型	方法和说明
BranchStatus	branchCommit(BranchType branchType, String xid, long branchId, String resourceId, String applicationData)
Long	branchRegister(BranchType branchType, String resourceId, String clientId, String xid, String applicationData, String lockKeys)
void	branchReport(BranchType branchType, String xid, long branchId, BranchStatus status, String applicationData)
BranchStatus	branchRollback(BranchType branchType, String xid, long branchId, String resourceId, String applicationData)
static DefaultResourceManager	get() Get resource manager.
BranchType	getBranchType()
Map<String,Resource>	getManagedResources()
ResourceManager	getResourceManager(BranchType branchType) get ResourceManager by Resource Type
protected void	initResourceManagers()
boolean	lockQuery(BranchType branchType, String resourceId, String xid, String lockKeys)
static void	mockResourceManager(BranchType branchType, ResourceManager rm) only for mock
void	registerResource(Resource resource)
void	unregisterResource(Resource resource)

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

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

字段详细资料

resourceManagers

protected static Map<BranchType,ResourceManager> resourceManagers

all resource managers

方法详细资料

get

public static DefaultResourceManager get()

Get resource manager.

返回:

the resource manager

mockResourceManager

public static void mockResourceManager(BranchType branchType,
                                       ResourceManager rm)

only for mock

参数:

branchType -

rm -

initResourceManagers

protected void initResourceManagers()

branchCommit

public BranchStatus branchCommit(BranchType branchType,
                                 String xid,
                                 long branchId,
                                 String resourceId,
                                 String applicationData)
                          throws TransactionException

指定者:

branchCommit 在接口中 ResourceManagerInbound

抛出:

TransactionException

branchRollback

public BranchStatus branchRollback(BranchType branchType,
                                   String xid,
                                   long branchId,
                                   String resourceId,
                                   String applicationData)
                            throws TransactionException

指定者:

branchRollback 在接口中 ResourceManagerInbound

抛出:

TransactionException

branchRegister

public Long branchRegister(BranchType branchType,
                           String resourceId,
                           String clientId,
                           String xid,
                           String applicationData,
                           String lockKeys)
                    throws TransactionException

指定者:

branchRegister 在接口中 ResourceManagerOutbound

抛出:

TransactionException

branchReport

public void branchReport(BranchType branchType,
                         String xid,
                         long branchId,
                         BranchStatus status,
                         String applicationData)
                  throws TransactionException

指定者:

branchReport 在接口中 ResourceManagerOutbound

抛出:

TransactionException

lockQuery

public boolean lockQuery(BranchType branchType,
                         String resourceId,
                         String xid,
                         String lockKeys)
                  throws TransactionException

指定者:

lockQuery 在接口中 ResourceManagerOutbound

抛出:

TransactionException

registerResource

public void registerResource(Resource resource)

指定者:

registerResource 在接口中 ResourceManager

unregisterResource

public void unregisterResource(Resource resource)

指定者:

unregisterResource 在接口中 ResourceManager

getManagedResources

public Map<String,Resource> getManagedResources()

指定者:

getManagedResources 在接口中 ResourceManager

getResourceManager

public ResourceManager getResourceManager(BranchType branchType)

get ResourceManager by Resource Type

参数:

branchType -

返回:

getBranchType

public BranchType getBranchType()

指定者:

getBranchType 在接口中 ResourceManager