类 com.taobao.metamorphosis.transaction.TransactionId
的使用

使用 TransactionId 的软件包

com.taobao.metamorphosis.client.producer
com.taobao.metamorphosis.client.transaction
com.taobao.metamorphosis.network
com.taobao.metamorphosis.server
com.taobao.metamorphosis.server.assembly
com.taobao.metamorphosis.server.network
com.taobao.metamorphosis.server.transaction
com.taobao.metamorphosis.server.transaction.store
com.taobao.metamorphosis.transaction

com.taobao.metamorphosis.client.producer 中 TransactionId 的使用

返回 TransactionId 的 com.taobao.metamorphosis.client.producer 中的方法

protected TransactionId

SimpleMessageProducer.getTransactionId() 返回事务id

com.taobao.metamorphosis.client.transaction 中 TransactionId 的使用

返回 TransactionId 的 com.taobao.metamorphosis.client.transaction 中的方法

TransactionId

TransactionContext.getTransactionId()

com.taobao.metamorphosis.network 中 TransactionId 的使用

返回 TransactionId 的 com.taobao.metamorphosis.network 中的方法

TransactionId

PutCommand.getTransactionId()

参数类型为 TransactionId 的 com.taobao.metamorphosis.network 中的方法

void	PutCommand.setTransactionId(TransactionId transactionId)

参数类型为 TransactionId 的 com.taobao.metamorphosis.network 中的构造方法

PutCommand(String topic, int partition, byte[] data, int flag, int checkSum, TransactionId transactionId, Integer opaque)

PutCommand(String topic, int partition, byte[] data, TransactionId transactionId, int flag, Integer opaque)

com.taobao.metamorphosis.server 中 TransactionId 的使用

返回 TransactionId 的 com.taobao.metamorphosis.server 中的方法

TransactionId[]	CommandProcessorFilter.getPreparedTransactions(SessionContext context, String uniqueQualifier)
TransactionId[]	CommandProcessor.getPreparedTransactions(SessionContext context, String uniqueQualifier)

参数类型为 TransactionId 的 com.taobao.metamorphosis.server 中的方法

void	CommandProcessorFilter.beginTransaction(SessionContext context, TransactionId xid, int seconds)
void	CommandProcessor.beginTransaction(SessionContext context, TransactionId xid, int seconds)
void	CommandProcessorFilter.commitTransaction(SessionContext context, TransactionId xid, boolean onePhase)
void	CommandProcessor.commitTransaction(SessionContext context, TransactionId xid, boolean onePhase)
void	CommandProcessorFilter.forgetTransaction(SessionContext context, TransactionId xid)
void	CommandProcessor.forgetTransaction(SessionContext context, TransactionId xid)
Transaction	CommandProcessorFilter.getTransaction(SessionContext context, TransactionId xid)
Transaction	CommandProcessor.getTransaction(SessionContext context, TransactionId xid)
int	CommandProcessorFilter.prepareTransaction(SessionContext context, TransactionId xid)
int	CommandProcessor.prepareTransaction(SessionContext context, TransactionId xid)
void	CommandProcessorFilter.rollbackTransaction(SessionContext context, TransactionId xid)
void	CommandProcessor.rollbackTransaction(SessionContext context, TransactionId xid)

com.taobao.metamorphosis.server.assembly 中 TransactionId 的使用

返回 TransactionId 的 com.taobao.metamorphosis.server.assembly 中的方法

TransactionId[]	TransactionalCommandProcessor.getPreparedTransactions(SessionContext context, String uniqueQualifier)
TransactionId[]	BrokerCommandProcessor.getPreparedTransactions(SessionContext context, String uniqueQualifier)

返回变量类型为 TransactionId 的类型的 com.taobao.metamorphosis.server.assembly 中的方法

Map<TransactionId,XATransaction>

TransactionalCommandProcessor.getXAHeuristicTransactions()

参数类型为 TransactionId 的 com.taobao.metamorphosis.server.assembly 中的方法

void	TransactionalCommandProcessor.beginTransaction(SessionContext context, TransactionId xid, int seconds)
void	BrokerCommandProcessor.beginTransaction(SessionContext context, TransactionId xid, int seconds)
void	TransactionalCommandProcessor.commitTransaction(SessionContext context, TransactionId xid, boolean onePhase)
void	BrokerCommandProcessor.commitTransaction(SessionContext context, TransactionId xid, boolean onePhase)
void	TransactionalCommandProcessor.forgetTransaction(SessionContext context, TransactionId xid)
void	BrokerCommandProcessor.forgetTransaction(SessionContext context, TransactionId xid)
Transaction	TransactionalCommandProcessor.getTransaction(SessionContext context, TransactionId xid)
Transaction	BrokerCommandProcessor.getTransaction(SessionContext context, TransactionId xid)
int	TransactionalCommandProcessor.prepareTransaction(SessionContext context, TransactionId xid)
int	BrokerCommandProcessor.prepareTransaction(SessionContext context, TransactionId xid)
void	TransactionalCommandProcessor.rollbackTransaction(SessionContext context, TransactionId xid)
void	BrokerCommandProcessor.rollbackTransaction(SessionContext context, TransactionId xid)

com.taobao.metamorphosis.server.network 中 TransactionId 的使用

返回变量类型为 TransactionId 的类型的 com.taobao.metamorphosis.server.network 中的方法

ConcurrentHashMap<TransactionId,Transaction>	SessionContextImpl.getTransactions()
ConcurrentHashMap<TransactionId,Transaction>	SessionContext.getTransactions()

参数类型为 TransactionId 的 com.taobao.metamorphosis.server.network 中的方法

static SessionContext

SessionContextHolder.getOrCreateSessionContext(com.taobao.gecko.service.Connection conn, TransactionId xid)

com.taobao.metamorphosis.server.transaction 中 TransactionId 的使用

返回 TransactionId 的 com.taobao.metamorphosis.server.transaction 中的方法

TransactionId	XATransaction.getTransactionId()
abstract TransactionId	Transaction.getTransactionId()
TransactionId	LocalTransaction.getTransactionId()

参数类型为 TransactionId 的 com.taobao.metamorphosis.server.transaction 中的方法

void	TransactionStore.commit(TransactionId txid, boolean wasPrepared)
void	TransactionStore.prepare(TransactionId txid)
void	TransactionStore.rollback(TransactionId txid)

com.taobao.metamorphosis.server.transaction.store 中 TransactionId 的使用

参数类型为 TransactionId 的 com.taobao.metamorphosis.server.transaction.store 中的方法

void	JournalTransactionStore.commit(TransactionId txid, boolean wasPrepared)
void	JournalTransactionStore.prepare(TransactionId txid)
JournalTransactionStore.Tx	JournalTransactionStore.replayCommit(TransactionId txid, boolean wasPrepared)
void	JournalTransactionStore.replayPrepare(TransactionId txid)
void	JournalTransactionStore.replayRollback(TransactionId txid)
void	JournalTransactionStore.rollback(TransactionId txid)

com.taobao.metamorphosis.transaction 中 TransactionId 的使用

com.taobao.metamorphosis.transaction 中 TransactionId 的子类

class	LocalTransactionId 本地事务id
class	NullTransactionId null transactionId object
class	XATransactionId XA事务id

返回 TransactionId 的 com.taobao.metamorphosis.transaction 中的方法

TransactionId	TransactionInfo.getTransactionId()
static TransactionId	TransactionId.valueOf(String key)

参数类型为 TransactionId 的 com.taobao.metamorphosis.transaction 中的构造方法

TransactionInfo(TransactionId transactionId, String sessionId, TransactionInfo.TransactionType type)

TransactionInfo(TransactionId transactionId, String sessionId, TransactionInfo.TransactionType type, String uniqueQualifier)

TransactionInfo(TransactionId transactionId, String sessionId, TransactionInfo.TransactionType type, String uniqueQualifier, int timeout)