in omega/omega-transaction/src/main/java/org/apache/servicecomb/pack/omega/transaction/TransactionContextHelper.java [27:42]
protected TransactionContext extractTransactionContext(Object[] args) {
if (args != null && args.length > 0) {
for (Object arg : args) {
// check the TransactionContext first
if (arg instanceof TransactionContext) {
return (TransactionContext) arg;
}
if (arg instanceof TransactionContextProperties) {
TransactionContextProperties transactionContextProperties = (TransactionContextProperties) arg;
return new TransactionContext(transactionContextProperties.getGlobalTxId(),
transactionContextProperties.getLocalTxId());
}
}
}
return null;
}