X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2Fbase%2Fmessages%2FApplySnapshot.java;h=c9660d9a4a2405e8cb7dbea3abd7721816007264;hp=3c43d809b9c55ed5456850e0b875a1bb2df433a1;hb=b4bf55727093657662d8c16a50fa85f87978a586;hpb=3fda1a923defdbf18849c6080c3aa19f1ebf2c5f diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/base/messages/ApplySnapshot.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/base/messages/ApplySnapshot.java index 3c43d809b9..c9660d9a4a 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/base/messages/ApplySnapshot.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/base/messages/ApplySnapshot.java @@ -5,36 +5,47 @@ * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ - package org.opendaylight.controller.cluster.raft.base.messages; -import com.google.common.base.Preconditions; -import javax.annotation.Nonnull; -import org.opendaylight.controller.cluster.raft.Snapshot; +import static java.util.Objects.requireNonNull; + +import akka.dispatch.ControlMessage; +import org.eclipse.jdt.annotation.NonNull; +import org.opendaylight.controller.cluster.raft.persisted.Snapshot; /** - * Internal message, issued by follower to its actor + * Internal message, issued by follower to its actor. */ -public class ApplySnapshot { +public class ApplySnapshot implements ControlMessage { + private static final Callback NOOP_CALLBACK = new Callback() { + @Override + public void onSuccess() { + // No-op + } + + @Override + public void onFailure() { + // No-op + } + }; + private final Snapshot snapshot; private final Callback callback; - public ApplySnapshot(Snapshot snapshot) { + public ApplySnapshot(@NonNull Snapshot snapshot) { this(snapshot, NOOP_CALLBACK); } - public ApplySnapshot(@Nonnull Snapshot snapshot, @Nonnull Callback callback) { - this.snapshot = Preconditions.checkNotNull(snapshot); - this.callback = Preconditions.checkNotNull(callback); + public ApplySnapshot(@NonNull Snapshot snapshot, @NonNull Callback callback) { + this.snapshot = requireNonNull(snapshot); + this.callback = requireNonNull(callback); } - @Nonnull - public Snapshot getSnapshot() { + public @NonNull Snapshot getSnapshot() { return snapshot; } - @Nonnull - public Callback getCallback() { + public @NonNull Callback getCallback() { return callback; } @@ -43,14 +54,4 @@ public class ApplySnapshot { void onFailure(); } - - public static Callback NOOP_CALLBACK = new Callback() { - @Override - public void onSuccess() { - } - - @Override - public void onFailure() { - } - }; }