private Optional<SnapshotHolder> snapshot;
- public AbstractLeader(RaftActorContext context) {
- super(context, RaftState.Leader);
+ protected AbstractLeader(RaftActorContext context, RaftState state) {
+ super(context, state);
setLeaderPayloadVersion(context.getPayloadVersion());
}
@Override
- public void close() throws Exception {
+ public void close() {
stopHeartBeat();
}