*
* @author Robert Varga
*/
-public final class IncrementTransactionSequenceRequest extends TransactionRequest<IncrementTransactionSequenceRequest> {
+public final class IncrementTransactionSequenceRequest extends
+ AbstractReadTransactionRequest<IncrementTransactionSequenceRequest> {
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);
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;
- }
}