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%2Fcommands%2FIncrementTransactionSequenceSuccess.java;fp=opendaylight%2Fmd-sal%2Fcds-access-api%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Faccess%2Fcommands%2FIncrementTransactionSequenceSuccess.java;h=e462edc4d80acca0a604c3b8ae3c25bd86c79e66;hp=a147545dd9a84bab87adf68d045c67cfeed9726d;hb=d92bd0e575983b3d6a09a73089ef8f9c62f94eaa;hpb=e085f22bb1934959f9d6f7f4368c1afe964b1e07 diff --git a/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/IncrementTransactionSequenceSuccess.java b/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/IncrementTransactionSequenceSuccess.java index a147545dd9..e462edc4d8 100644 --- a/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/IncrementTransactionSequenceSuccess.java +++ b/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/IncrementTransactionSequenceSuccess.java @@ -7,7 +7,7 @@ */ package org.opendaylight.controller.cluster.access.commands; -import java.io.Serial; +import java.io.ObjectInput; import org.opendaylight.controller.cluster.access.ABIVersion; import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier; @@ -15,20 +15,33 @@ import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier * Successful reply to an {@link IncrementTransactionSequenceRequest}. */ public final class IncrementTransactionSequenceSuccess extends TransactionSuccess { - @Serial + interface SerialForm extends TransactionSuccess.SerialForm { + @Override + default IncrementTransactionSequenceSuccess readExternal(final ObjectInput it, + final TransactionIdentifier target, final long sequence) { + return new IncrementTransactionSequenceSuccess(target, sequence); + } + } + + @java.io.Serial private static final long serialVersionUID = 1L; + private IncrementTransactionSequenceSuccess(final IncrementTransactionSequenceSuccess success, + final ABIVersion version) { + super(success, version); + } + public IncrementTransactionSequenceSuccess(final TransactionIdentifier target, final long sequence) { super(target, sequence); } @Override - protected IncrementTransactionSequenceSuccessProxyV1 externalizableProxy(final ABIVersion version) { - return new IncrementTransactionSequenceSuccessProxyV1(this); + protected SerialForm externalizableProxy(final ABIVersion version) { + return ABIVersion.MAGNESIUM.lt(version) ? new ITSS(this) : new IncrementTransactionSequenceSuccessProxyV1(this); } @Override protected IncrementTransactionSequenceSuccess cloneAsVersion(final ABIVersion version) { - return this; + return new IncrementTransactionSequenceSuccess(this, version); } }