- private TransactionSuccess<?> handleTransactionAbort(final TransactionAbortRequest request,
- final RequestEnvelope envelope, final long now) throws RequestException {
- openTransaction.abort();
- return new TransactionAbortSuccess(openTransaction.getIdentifier(), request.getSequence());
+ @Override
+ void retire() {
+ // No-op
+ }
+
+ private void handleModifyTransaction(final ModifyTransactionRequest request, final RequestEnvelope envelope,
+ final long now) {
+ // The only valid request here is with abort protocol
+ final java.util.Optional<PersistenceProtocol> optProto = request.getPersistenceProtocol();
+ Preconditions.checkArgument(optProto.isPresent(), "Commit protocol is missing in %s", request);
+ Preconditions.checkArgument(optProto.get() == PersistenceProtocol.ABORT, "Unsupported commit protocol in %s",
+ request);
+ openTransaction.abort(() -> recordAndSendSuccess(envelope, now,
+ new ModifyTransactionSuccess(request.getTarget(), request.getSequence())));