+ protected abstract <T> void onTransactionReady(@Nonnull TransactionIdentifier transaction,
+ @Nonnull Collection<Future<T>> cohortFutures);
+
+ /**
+ * Callback invoked when the internal TransactionContext has been created for a transaction.
+ *
+ * @param transactionId the ID of the transaction.
+ */
+ protected abstract void onTransactionContextCreated(@Nonnull TransactionIdentifier transactionId);
+
+ private static TransactionContext createLocalTransactionContext(final LocalTransactionFactory factory,
+ final TransactionProxy parent) {