- private void onApplySnapshot(Snapshot snapshot) {
- if(log.isDebugEnabled()) {
- log.debug("{}: ApplySnapshot called on Follower Actor " +
- "snapshotIndex:{}, snapshotTerm:{}", context.getId(), snapshot.getLastAppliedIndex(),
- snapshot.getLastAppliedTerm());
- }
-
- cohort.applySnapshot(snapshot.getState());
+ private void onApplySnapshot(ApplySnapshot message) {
+ log.info("{}: Applying snapshot on follower with snapshotIndex: {}, snapshotTerm: {}", context.getId(),
+ message.getSnapshot().getLastAppliedIndex(), message.getSnapshot().getLastAppliedTerm());