X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft-example%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fexample%2FExampleActor.java;h=9b7c2e8d4b0f3af9d522a55616d86a82f72a9cda;hp=5ab3f69bea994d60644cca47b9694205ae2ab039;hb=11dadddb4d9ba26ae0b1795921c7a218a6d893c2;hpb=1447e0132075bbd3013aa41b98384a373bd82d1a diff --git a/opendaylight/md-sal/sal-akka-raft-example/src/main/java/org/opendaylight/controller/cluster/example/ExampleActor.java b/opendaylight/md-sal/sal-akka-raft-example/src/main/java/org/opendaylight/controller/cluster/example/ExampleActor.java index 5ab3f69bea..9b7c2e8d4b 100644 --- a/opendaylight/md-sal/sal-akka-raft-example/src/main/java/org/opendaylight/controller/cluster/example/ExampleActor.java +++ b/opendaylight/md-sal/sal-akka-raft-example/src/main/java/org/opendaylight/controller/cluster/example/ExampleActor.java @@ -47,7 +47,7 @@ public class ExampleActor extends RaftActor implements RaftActorRecoveryCohort, public ExampleActor(String id, Map peerAddresses, Optional configParams) { - super(id, peerAddresses, configParams); + super(id, peerAddresses, configParams, (short)0); setPersistence(true); roleChangeNotifier = createRoleChangeNotifier(id); } @@ -79,10 +79,10 @@ public class ExampleActor extends RaftActor implements RaftActorRecoveryCohort, 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()); } @@ -226,4 +226,9 @@ public class ExampleActor extends RaftActor implements RaftActorRecoveryCohort, protected RaftActorSnapshotCohort getRaftActorSnapshotCohort() { return this; } + + @Override + public byte[] getRestoreFromSnapshot() { + return null; + } }