- public synchronized CheckedFuture<Void, TransactionCommitFailedException> submit() {
- final ListenableFuture<Void> commmitFutureAsVoid = Futures.transform(commit(),
- (Function<RpcResult<TransactionStatus>, Void>) input -> null);
-
- return Futures.makeChecked(commmitFutureAsVoid,
- input -> new TransactionCommitFailedException("Submit of transaction " + getIdentifier() + " failed",
- input));
- }
-
- @Override
- public synchronized ListenableFuture<RpcResult<TransactionStatus>> performCommit() {