boolean handleSnapshotMessage(Object message) {
if(message instanceof ApplySnapshot ) {
- onApplySnapshot(((ApplySnapshot) message).getSnapshot());
+ onApplySnapshot((ApplySnapshot) message);
return true;
} else if (message instanceof SaveSnapshotSuccess) {
onSaveSnapshotSuccess((SaveSnapshotSuccess) message);
context.getSnapshotManager().commit(sequenceNumber, currentBehavior);
}
- private void onApplySnapshot(Snapshot snapshot) {
+ private void onApplySnapshot(ApplySnapshot message) {
log.info("{}: Applying snapshot on follower with snapshotIndex: {}, snapshotTerm: {}", context.getId(),
- snapshot.getLastAppliedIndex(), snapshot.getLastAppliedTerm());
+ message.getSnapshot().getLastAppliedIndex(), message.getSnapshot().getLastAppliedTerm());
- context.getSnapshotManager().apply(snapshot);
+ context.getSnapshotManager().apply(message);
}
}