X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fmessages%2FShardLeaderStateChanged.java;h=cbf2cf9e0fb189d5b2c3ea2e090dca6dd29d111a;hb=b65e66f7b1bafb0d0c5fbe1c569835eb890f672a;hp=dbd031076c15fdca20b55be61ab5d8284780ad4c;hpb=c1336f9b497bc6867536a24f629c3f0b002ccb2f;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ShardLeaderStateChanged.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ShardLeaderStateChanged.java index dbd031076c..cbf2cf9e0f 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ShardLeaderStateChanged.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ShardLeaderStateChanged.java @@ -7,12 +7,13 @@ */ package org.opendaylight.controller.cluster.datastore.messages; -import com.google.common.base.Preconditions; +import static java.util.Objects.requireNonNull; + import java.util.Optional; -import javax.annotation.Nonnull; -import javax.annotation.Nullable; +import org.eclipse.jdt.annotation.NonNull; +import org.eclipse.jdt.annotation.Nullable; import org.opendaylight.controller.cluster.notifications.LeaderStateChanged; -import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTree; +import org.opendaylight.yangtools.yang.data.api.schema.tree.ReadOnlyDataTree; /** * A local message derived from LeaderStateChanged containing additional Shard-specific info that is sent @@ -22,22 +23,21 @@ import org.opendaylight.yangtools.yang.data.api.schema.tree.DataTree; * @author Thomas Pantelis */ public class ShardLeaderStateChanged extends LeaderStateChanged { + private final ReadOnlyDataTree localShardDataTree; - private final DataTree localShardDataTree; - - public ShardLeaderStateChanged(@Nonnull String memberId, @Nullable String leaderId, - @Nonnull DataTree localShardDataTree, short leaderPayloadVersion) { + public ShardLeaderStateChanged(@NonNull String memberId, @Nullable String leaderId, + @NonNull ReadOnlyDataTree localShardDataTree, short leaderPayloadVersion) { super(memberId, leaderId, leaderPayloadVersion); - this.localShardDataTree = Preconditions.checkNotNull(localShardDataTree); + this.localShardDataTree = requireNonNull(localShardDataTree); } - public ShardLeaderStateChanged(@Nonnull String memberId, @Nullable String leaderId, + public ShardLeaderStateChanged(@NonNull String memberId, @Nullable String leaderId, short leaderPayloadVersion) { super(memberId, leaderId, leaderPayloadVersion); this.localShardDataTree = null; } - public @Nonnull Optional getLocalShardDataTree() { + public @NonNull Optional getLocalShardDataTree() { return Optional.ofNullable(localShardDataTree); } }