io.seata.rm

类 AbstractRMHandler

java.lang.Object

io.seata.core.exception.AbstractExceptionHandler

io.seata.rm.AbstractRMHandler

所有已实现的接口:

RMInboundHandler, TransactionMessageHandler

直接已知子类:

DefaultRMHandler

public abstract class AbstractRMHandler
extends AbstractExceptionHandler
implements RMInboundHandler, TransactionMessageHandler

The Abstract RM event handler

作者:

sharajava

嵌套类概要

从类继承的嵌套类/接口 io.seata.core.exception.AbstractExceptionHandler

AbstractExceptionHandler.Callback<T extends AbstractTransactionRequest,S extends AbstractTransactionResponse>

构造器概要

构造器

构造器和说明
AbstractRMHandler()

方法概要

限定符和类型	方法和说明
protected void	doBranchCommit(BranchCommitRequest request, BranchCommitResponse response) Do branch commit.
protected void	doBranchRollback(BranchRollbackRequest request, BranchRollbackResponse response) Do branch rollback.
abstract BranchType	getBranchType()
protected abstract ResourceManager	getResourceManager() get resource manager implement
BranchCommitResponse	handle(BranchCommitRequest request)
BranchRollbackResponse	handle(BranchRollbackRequest request)
AbstractResultMessage	onRequest(AbstractMessage request, RpcContext context)
void	onResponse(AbstractResultMessage response, RpcContext context)

从类继承的方法 io.seata.core.exception.AbstractExceptionHandler

exceptionHandleTemplate

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

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

构造器详细资料

AbstractRMHandler

public AbstractRMHandler()

方法详细资料

handle

public BranchCommitResponse handle(BranchCommitRequest request)

指定者:

handle 在接口中 RMInboundHandler

handle

public BranchRollbackResponse handle(BranchRollbackRequest request)

指定者:

handle 在接口中 RMInboundHandler

doBranchCommit

protected void doBranchCommit(BranchCommitRequest request,
                              BranchCommitResponse response)
                       throws TransactionException

Do branch commit.

参数:

request - the request

response - the response

抛出:

TransactionException - the transaction exception

doBranchRollback

protected void doBranchRollback(BranchRollbackRequest request,
                                BranchRollbackResponse response)
                         throws TransactionException

Do branch rollback.

参数:

request - the request

response - the response

抛出:

TransactionException - the transaction exception

getResourceManager

protected abstract ResourceManager getResourceManager()

get resource manager implement

返回:

onRequest

public AbstractResultMessage onRequest(AbstractMessage request,
                                       RpcContext context)

指定者:

onRequest 在接口中 TransactionMessageHandler

onResponse

public void onResponse(AbstractResultMessage response,
                       RpcContext context)

指定者:

onResponse 在接口中 TransactionMessageHandler

getBranchType

public abstract BranchType getBranchType()