TransactionRepository compensableRepository = this.beanFactory.getCompensableRepository();
TransactionXid globalXid = transactionContext.getXid();
CompensableTransactionImpl transaction = new CompensableTransactionImpl(transactionContext);
transaction = new CompensableTransactionImpl(transactionContext);
transaction.setBeanFactory(this.beanFactory);
<BUG>compensableLogger.createTransaction(transaction.getTransactionArchive());
compensableManager.associateThread(transaction);</BUG>
compensableRepository.putTransaction(globalXid, transaction);
return transaction;
}

TransactionRepository compensableRepository = this.beanFactory.getCompensableRepository();
TransactionXid globalXid = transactionContext.getXid();
CompensableTransactionImpl transaction = new CompensableTransactionImpl(transactionContext);
transaction = new CompensableTransactionImpl(transactionContext);
transaction.setBeanFactory(this.beanFactory);
compensableLogger.createTransaction(transaction.getTransactionArchive());
logger.info("{}| compensable transaction begin!",
ByteUtils.byteArrayToString(globalXid.getGlobalTransactionId()));
compensableManager.associateThread(transaction);
compensableRepository.putTransaction(globalXid, transaction);
return transaction;
}
