- protected ShardDataTreeCohort finishTransaction(final ReadWriteShardDataTreeTransaction transaction) {
- Preconditions.checkState(openTransaction != null, "Attempted to finish transaction %s while none is outstanding", transaction);
+ void abortTransaction(final AbstractShardDataTreeTransaction<?> transaction, final Runnable callback) {
+ abortFromTransactionActor(transaction);
+ dataTree.abortTransaction(transaction, callback);
+ }
+
+ @Override
+ ShardDataTreeCohort finishTransaction(final ReadWriteShardDataTreeTransaction transaction) {
+ Preconditions.checkState(openTransaction != null,
+ "Attempted to finish transaction %s while none is outstanding", transaction);