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%2FTimedRunnable.java;h=f16e5e2b59e1d99d1eb9ab78501c8f00fdff60cb;hb=e66759266dc43d5f58b2837aca5047b42c205e4a;hp=95606657562ce865e3664d2973e248a1f069a3ca;hpb=341a9dd5ff4c596aada3a0c1fa58c17c50d7521f;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/TimedRunnable.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/TimedRunnable.java index 9560665756..f16e5e2b59 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/TimedRunnable.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/TimedRunnable.java @@ -7,8 +7,9 @@ */ package org.opendaylight.controller.cluster.raft; +import static java.util.Objects.requireNonNull; + import akka.actor.Cancellable; -import com.google.common.base.Preconditions; import scala.concurrent.duration.FiniteDuration; /** @@ -26,11 +27,10 @@ abstract class TimedRunnable implements Runnable { private final Cancellable cancelTimer; private boolean canRun = true; - TimedRunnable(FiniteDuration timeout, RaftActor actor) { - Preconditions.checkNotNull(timeout); - Preconditions.checkNotNull(actor); - cancelTimer = actor.getContext().system().scheduler().scheduleOnce(timeout, actor.self(), - (Runnable) this::cancel, actor.getContext().system().dispatcher(), actor.self()); + TimedRunnable(final FiniteDuration timeout, final RaftActor actor) { + cancelTimer = requireNonNull(actor).getContext().system().scheduler() + .scheduleOnce(requireNonNull(timeout), actor.self(), (Runnable) this::cancel, + actor.getContext().system().dispatcher(), actor.self()); } @Override