- private void commitTransaction(DOMStoreWriteTransaction transaction) {
- DOMStoreThreePhaseCommitCohort commitCohort = transaction.ready();
- try {
- commitCohort.preCommit().get();
- commitCohort.commit().get();
- } catch (Exception e) {
- log.error("{}: Failed to commit Tx on recovery", shardName, e);
- }
+ private void commitTransaction(PruningDataTreeModification tx) throws DataValidationFailedException {
+ DataTreeModification delegate = tx.getDelegate();
+ delegate.ready();
+ store.validate(delegate);
+ store.commit(store.prepare(delegate));