- return new LocalThreePhaseCommitCohort(actorContext, leader, tx, tree) {
- @Override
- protected void transactionAborted(final SnapshotBackedWriteTransaction<TransactionIdentifier> transaction) {
- // No-op
- LOG.debug("Transaction {} aborted", transaction);
- }
+ return new LocalThreePhaseCommitCohort(actorContext, leader, tx, tree);
+ }
+
+ @SuppressWarnings("unchecked")
+ @Override
+ public LocalThreePhaseCommitCohort onTransactionReady(@Nonnull DOMStoreWriteTransaction tx,
+ @Nullable Exception operationError) {
+ if(operationError != null) {
+ return new LocalThreePhaseCommitCohort(actorContext, leader,
+ (SnapshotBackedWriteTransaction<TransactionIdentifier>)tx, operationError);
+ }