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%2FReadyLocalTransactionSerializer.java;h=c44f9105c0c093e16005b13e888d37bf64a5b861;hb=99f80f27bee37bb23e345420bf14bb7bb4793c28;hp=53731fa49170ffd22aa39512deebd825f7e12c08;hpb=731e7284cf0895fdb1b89427f91762e80e67c2ff;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ReadyLocalTransactionSerializer.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ReadyLocalTransactionSerializer.java index 53731fa491..c44f9105c0 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ReadyLocalTransactionSerializer.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/ReadyLocalTransactionSerializer.java @@ -7,10 +7,12 @@ */ package org.opendaylight.controller.cluster.datastore.messages; +import static com.google.common.base.Preconditions.checkArgument; +import static java.util.Objects.requireNonNull; + import akka.actor.ExtendedActorSystem; import akka.serialization.JSerializer; import akka.util.ClassLoaderObjectInputStream; -import com.google.common.base.Preconditions; import java.io.ByteArrayInputStream; import java.io.IOException; import org.apache.commons.lang3.SerializationUtils; @@ -27,7 +29,7 @@ public final class ReadyLocalTransactionSerializer extends JSerializer { private final ExtendedActorSystem system; public ReadyLocalTransactionSerializer(final ExtendedActorSystem system) { - this.system = Preconditions.checkNotNull(system); + this.system = requireNonNull(system); } @Override @@ -42,7 +44,7 @@ public final class ReadyLocalTransactionSerializer extends JSerializer { @Override public byte[] toBinary(final Object obj) { - Preconditions.checkArgument(obj instanceof ReadyLocalTransaction, "Unsupported object type %s", obj.getClass()); + checkArgument(obj instanceof ReadyLocalTransaction, "Unsupported object type %s", obj.getClass()); final ReadyLocalTransaction readyLocal = (ReadyLocalTransaction) obj; final BatchedModifications batched = new BatchedModifications(readyLocal.getTransactionId(), readyLocal.getRemoteVersion()); @@ -69,7 +71,7 @@ public final class ReadyLocalTransactionSerializer extends JSerializer { private final BatchedModifications message; BatchedCursor(final BatchedModifications message) { - this.message = Preconditions.checkNotNull(message); + this.message = requireNonNull(message); } @Override