- }
-
- void syncCommitTransaction(final ReadWriteShardDataTreeTransaction transaction)
- throws ExecutionException, InterruptedException {
- ShardDataTreeCohort commitCohort = store.finishTransaction(transaction);
- commitCohort.preCommit().get();
- commitCohort.commit().get();
- }
-
- @Override
- public void applySnapshot(final byte[] snapshotBytes) {
- // Since this will be done only on Recovery or when this actor is a Follower
- // we can safely commit everything in here. We not need to worry about event notifications
- // as they would have already been disabled on the follower
-
- log.info("{}: Applying snapshot", logId);
- deserializeAndApplySnapshot(snapshotBytes);