- public ListenableFuture<RpcResult<TransactionStatus>> commit(final Object identifier) {
- LOG.trace("{}: Commit", id);
-
- final CheckedFuture<Void, TransactionCommitFailedException> submit = submit(identifier);
- return Futures.transform(submit, new Function<Void, RpcResult<TransactionStatus>>() {
- @Nullable
- @Override
- public RpcResult<TransactionStatus> apply(@Nullable final Void input) {
- return RpcResultBuilder.success(TransactionStatus.SUBMITED).build();
- }
- });
+ private static TransactionCommitFailedException newTransactionCommitFailedException(final Throwable failure,
+ final Object identifier) {
+ return new TransactionCommitFailedException(
+ String.format("Commit of transaction %s failed", identifier), failure);