public ExampleActor(String id, Map<String, String> peerAddresses,
Optional<ConfigParams> configParams) {
- super(id, peerAddresses, configParams);
+ super(id, peerAddresses, configParams, (short)0);
setPersistence(true);
roleChangeNotifier = createRoleChangeNotifier(id);
}
if (getRaftState() == RaftState.Leader || getRaftState() == RaftState.IsolatedLeader) {
final String followers = ((Leader)this.getCurrentBehavior()).printFollowerStates();
LOG.debug("{} = {}, Peers={}, followers={}", getId(), getRaftState(),
- getRaftActorContext().getPeerAddresses().keySet(), followers);
+ getRaftActorContext().getPeerIds(), followers);
} else {
LOG.debug("{} = {}, Peers={}", getId(), getRaftState(),
- getRaftActorContext().getPeerAddresses().keySet());
+ getRaftActorContext().getPeerIds());
}
protected RaftActorSnapshotCohort getRaftActorSnapshotCohort() {
return this;
}
+
+ @Override
+ public byte[] getRestoreFromSnapshot() {
+ return null;
+ }
}