private boolean snapshotCaptureInitiated;
private SnapshotManager snapshotManager;
private DataPersistenceProvider persistenceProvider = new NonPersistentDataProvider();
+ private short payloadVersion;
public MockRaftActorContext(){
electionTerm = new ElectionTerm() {
this.persistenceProvider = persistenceProvider;
}
+ @Override
+ public short getPayloadVersion() {
+ return payloadVersion;
+ }
+
+ public void setPayloadVersion(short payloadVersion) {
+ this.payloadVersion = payloadVersion;
+ }
+
public static class SimpleReplicatedLog extends AbstractReplicatedLogImpl {
@Override public void appendAndPersist(
ReplicatedLogEntry replicatedLogEntry) {