X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fcds-access-api%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Faccess%2Fcommands%2FAbstractReadTransactionRequestProxyV1.java;h=e8539ea57b421f880d4d7506c61aa0dc3a9d7a36;hb=refs%2Fchanges%2F47%2F103447%2F26;hp=66bca1d7465e15e2da21ef669fb433f25420baff;hpb=e085f22bb1934959f9d6f7f4368c1afe964b1e07;p=controller.git diff --git a/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/AbstractReadTransactionRequestProxyV1.java b/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/AbstractReadTransactionRequestProxyV1.java index 66bca1d746..e8539ea57b 100644 --- a/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/AbstractReadTransactionRequestProxyV1.java +++ b/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/AbstractReadTransactionRequestProxyV1.java @@ -7,13 +7,6 @@ */ package org.opendaylight.controller.cluster.access.commands; -import akka.actor.ActorRef; -import java.io.IOException; -import java.io.ObjectInput; -import java.io.ObjectOutput; -import java.io.Serial; -import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier; - /** * Abstract base class for serialization proxies associated with {@link AbstractReadTransactionRequest}s. It implements * the initial (Boron) serialization format. @@ -23,38 +16,15 @@ import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier * @param Message type */ abstract class AbstractReadTransactionRequestProxyV1> - extends AbstractTransactionRequestProxy { - @Serial + extends AbstractTransactionRequestProxy implements AbstractReadTransactionRequest.SerialForm { + @java.io.Serial private static final long serialVersionUID = 1L; - private boolean snapshotOnly; - protected AbstractReadTransactionRequestProxyV1() { // For Externalizable } AbstractReadTransactionRequestProxyV1(final T request) { super(request); - snapshotOnly = request.isSnapshotOnly(); } - - @Override - public void writeExternal(final ObjectOutput out) throws IOException { - super.writeExternal(out); - out.writeBoolean(snapshotOnly); - } - - @Override - public void readExternal(final ObjectInput in) throws ClassNotFoundException, IOException { - super.readExternal(in); - snapshotOnly = in.readBoolean(); - } - - @Override - protected final T createRequest(final TransactionIdentifier target, final long sequence, final ActorRef replyTo) { - return createReadRequest(target, sequence, replyTo, snapshotOnly); - } - - @SuppressWarnings("checkstyle:hiddenField") - abstract T createReadRequest(TransactionIdentifier target, long sequence, ActorRef replyTo, boolean snapshotOnly); }