handleTransactionAbort((TransactionAbortRequest) request, envelope, now);
return null;
} else {
+ LOG.warn("Rejecting unsupported request {}", request);
throw new UnsupportedRequestException(request);
}
}
coordinatedCommit(envelope, now);
return null;
default:
+ LOG.warn("{}: rejecting unsupported protocol {}", history().persistenceId(), maybeProto.get());
throw new UnsupportedRequestException(request);
}
}