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%2FIncrementTransactionSequenceRequest.java;h=ffc0a68b8912481bfeca882545ff3626469025e0;hp=59faae42ccb82dd3042c1b6b6653a8923369168b;hb=b24517538beb4f44e6a9a96e68e4bf48156b480f;hpb=5d283236155c98907497ab3690273fb9b89d744f diff --git a/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/IncrementTransactionSequenceRequest.java b/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/IncrementTransactionSequenceRequest.java index 59faae42cc..ffc0a68b89 100644 --- a/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/IncrementTransactionSequenceRequest.java +++ b/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/IncrementTransactionSequenceRequest.java @@ -19,18 +19,28 @@ import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier * * @author Robert Varga */ -public final class IncrementTransactionSequenceRequest extends TransactionRequest { +public final class IncrementTransactionSequenceRequest extends + AbstractReadTransactionRequest { private static final long serialVersionUID = 1L; private final long increment; public IncrementTransactionSequenceRequest(final TransactionIdentifier identifier, final long sequence, - final ActorRef replyTo, final long increment) { - super(identifier, sequence, replyTo); + final ActorRef replyTo, final boolean snapshotOnly, final long increment) { + super(identifier, sequence, replyTo, snapshotOnly); Preconditions.checkArgument(increment >= 0); this.increment = increment; } + /** + * Return the sequence increment beyond this request's sequence. + * + * @return Sequence increment, guaranteed to be non-negative. + */ + public long getIncrement() { + return increment; + } + @Override protected IncrementTransactionSequenceRequestProxyV1 externalizableProxy(final ABIVersion version) { return new IncrementTransactionSequenceRequestProxyV1(this); @@ -40,13 +50,4 @@ public final class IncrementTransactionSequenceRequest extends TransactionReques protected IncrementTransactionSequenceRequest cloneAsVersion(final ABIVersion targetVersion) { return this; } - - /** - * Return the sequence increment beyond this request's sequence. - * - * @return Sequence increment, guaranteed to be non-negative. - */ - public long getIncrement() { - return increment; - } }