com.taobao.metamorphosis.server
接口 CommandProcessor

所有超级接口：

Service

所有已知实现类：

BrokerCommandProcessor, CommandProcessorFilter, GregorCommandProcessor, SamsaCommandProcessor, TransactionalCommandProcessor

public interface CommandProcessor
extends Service

meta的协议处理接口，封装meta的核心逻辑

作者：

boyan(boyan@taobao.com)

方法摘要

void	beginTransaction(SessionContext context, TransactionId xid, int seconds)
void	commitTransaction(SessionContext context, TransactionId xid, boolean onePhase)
void	forgetTransaction(SessionContext context, TransactionId xid)
TransactionId[]	getPreparedTransactions(SessionContext context, String uniqueQualifier)
Transaction	getTransaction(SessionContext context, TransactionId xid)
int	prepareTransaction(SessionContext context, TransactionId xid)
com.taobao.gecko.core.command.ResponseCommand	processGetCommand(GetCommand request, SessionContext ctx)
com.taobao.gecko.core.command.ResponseCommand	processGetCommand(GetCommand request, SessionContext ctx, boolean zeroCopy) Under conditions that cannot use notify-remoting directly.
com.taobao.gecko.core.command.ResponseCommand	processOffsetCommand(OffsetCommand request, SessionContext ctx)
void	processPutCommand(PutCommand request, SessionContext sessionContext, PutCallback cb)
void	processQuitCommand(QuitCommand request, SessionContext ctx)
com.taobao.gecko.core.command.ResponseCommand	processStatCommand(StatsCommand request, SessionContext ctx)
com.taobao.gecko.core.command.ResponseCommand	processVesionCommand(VersionCommand request, SessionContext ctx)
void	removeTransaction(XATransactionId xid)
void	rollbackTransaction(SessionContext context, TransactionId xid)

从接口 com.taobao.metamorphosis.server.Service 继承的方法

dispose, init

方法详细信息

processPutCommand

void processPutCommand(PutCommand request,
                       SessionContext sessionContext,
                       PutCallback cb)
                       throws Exception

抛出：

Exception

processGetCommand

com.taobao.gecko.core.command.ResponseCommand processGetCommand(GetCommand request,
                                                                SessionContext ctx)

processGetCommand

com.taobao.gecko.core.command.ResponseCommand processGetCommand(GetCommand request,
                                                                SessionContext ctx,
                                                                boolean zeroCopy)

Under conditions that cannot use notify-remoting directly.

processOffsetCommand

com.taobao.gecko.core.command.ResponseCommand processOffsetCommand(OffsetCommand request,
                                                                   SessionContext ctx)

processQuitCommand

void processQuitCommand(QuitCommand request,
                        SessionContext ctx)

processVesionCommand

com.taobao.gecko.core.command.ResponseCommand processVesionCommand(VersionCommand request,
                                                                   SessionContext ctx)

processStatCommand

com.taobao.gecko.core.command.ResponseCommand processStatCommand(StatsCommand request,
                                                                 SessionContext ctx)

removeTransaction

void removeTransaction(XATransactionId xid)

getTransaction

Transaction getTransaction(SessionContext context,
                           TransactionId xid)
                           throws MetamorphosisException,
                                  XAException

抛出：

MetamorphosisException

XAException

forgetTransaction

void forgetTransaction(SessionContext context,
                       TransactionId xid)
                       throws Exception

抛出：

Exception

rollbackTransaction

void rollbackTransaction(SessionContext context,
                         TransactionId xid)
                         throws Exception

抛出：

Exception

commitTransaction

void commitTransaction(SessionContext context,
                       TransactionId xid,
                       boolean onePhase)
                       throws Exception

抛出：

Exception

prepareTransaction

int prepareTransaction(SessionContext context,
                       TransactionId xid)
                       throws Exception

抛出：

Exception

beginTransaction

void beginTransaction(SessionContext context,
                      TransactionId xid,
                      int seconds)
                      throws Exception

抛出：

Exception

getPreparedTransactions

TransactionId[] getPreparedTransactions(SessionContext context,
                                        String uniqueQualifier)
                                        throws Exception

抛出：

Exception