X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fcds-access-api%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Faccess%2Fconcepts%2FRequest.java;fp=opendaylight%2Fmd-sal%2Fcds-access-api%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Faccess%2Fconcepts%2FRequest.java;h=093a3f1eb0c1cdedb4c957cfdb81c85b639ac6f2;hp=5c8df7874163908f8869986e3db819dff9f0c3b2;hb=b4bf55727093657662d8c16a50fa85f87978a586;hpb=9d4ff4c4045fdef38e3940d336d2825df29c4d65 diff --git a/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/concepts/Request.java b/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/concepts/Request.java index 5c8df78741..093a3f1eb0 100644 --- a/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/concepts/Request.java +++ b/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/concepts/Request.java @@ -7,11 +7,12 @@ */ package org.opendaylight.controller.cluster.access.concepts; +import static java.util.Objects.requireNonNull; + import akka.actor.ActorRef; import com.google.common.annotations.Beta; import com.google.common.base.MoreObjects.ToStringHelper; -import com.google.common.base.Preconditions; -import javax.annotation.Nonnull; +import org.eclipse.jdt.annotation.NonNull; import org.opendaylight.controller.cluster.access.ABIVersion; import org.opendaylight.yangtools.concepts.WritableIdentifier; @@ -27,16 +28,16 @@ import org.opendaylight.yangtools.concepts.WritableIdentifier; @Beta public abstract class Request> extends Message { private static final long serialVersionUID = 1L; - private final ActorRef replyTo; + private final @NonNull ActorRef replyTo; - protected Request(@Nonnull final T target, final long sequence, @Nonnull final ActorRef replyTo) { + protected Request(final @NonNull T target, final long sequence, final @NonNull ActorRef replyTo) { super(target, sequence); - this.replyTo = Preconditions.checkNotNull(replyTo); + this.replyTo = requireNonNull(replyTo); } - protected Request(@Nonnull final C request, @Nonnull final ABIVersion version) { + protected Request(final @NonNull C request, final @NonNull ABIVersion version) { super(request, version); - this.replyTo = Preconditions.checkNotNull(request.getReplyTo()); + this.replyTo = requireNonNull(request.getReplyTo()); } /** @@ -44,8 +45,7 @@ public abstract class Request toRequestFailure(@Nonnull RequestException cause); + public abstract @NonNull RequestFailure toRequestFailure(@NonNull RequestException cause); @Override protected ToStringHelper addToStringAttributes(final ToStringHelper toStringHelper) { @@ -64,5 +63,5 @@ public abstract class Request externalizableProxy(@Nonnull ABIVersion version); + protected abstract AbstractRequestProxy externalizableProxy(ABIVersion version); }