X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FRaftActorSnapshotMessageSupport.java;h=790ff89510ab222473a68b8105eab31c32158dd2;hb=dcf327e8c3a8a10e2a7a433e473157ed50395b99;hp=21c8ffa68e44763a14f0d5865ad03d8104e25d60;hpb=47b382cfd70014ff286c5a107da964f23f1df467;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorSnapshotMessageSupport.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorSnapshotMessageSupport.java index 21c8ffa68e..790ff89510 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorSnapshotMessageSupport.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorSnapshotMessageSupport.java @@ -7,7 +7,6 @@ */ package org.opendaylight.controller.cluster.raft; -import akka.actor.ActorRef; import akka.japi.Procedure; import akka.persistence.SaveSnapshotFailure; import akka.persistence.SaveSnapshotSuccess; @@ -30,23 +29,21 @@ class RaftActorSnapshotMessageSupport { private final RaftActorContext context; private final RaftActorBehavior currentBehavior; private final RaftActorSnapshotCohort cohort; - private final ActorRef raftActorRef; private final Logger log; private final Procedure createSnapshotProcedure = new Procedure() { @Override public void apply(Void notUsed) throws Exception { - cohort.createSnapshot(raftActorRef); + cohort.createSnapshot(context.getActor()); } }; RaftActorSnapshotMessageSupport(DataPersistenceProvider persistence, RaftActorContext context, - RaftActorBehavior currentBehavior, RaftActorSnapshotCohort cohort, ActorRef raftActorRef) { + RaftActorBehavior currentBehavior, RaftActorSnapshotCohort cohort) { this.persistence = persistence; this.context = context; this.currentBehavior = currentBehavior; this.cohort = cohort; - this.raftActorRef = raftActorRef; this.log = context.getLogger(); }