- return Futures.makeChecked(settableFuture, new Function<Exception, TransactionCommitFailedException>() {
- @Nullable
- @Override
- public TransactionCommitFailedException apply(@Nullable final Exception input) {
- final String message = "Submit of transaction " + identifier + " failed";
- return new TransactionCommitFailedException(message, input);
- }
- });
+ return FluentFuture.from(settableFuture);
+ }
+
+ private static TransactionCommitFailedException newTransactionCommitFailedException(final Throwable failure,
+ final Object identifier) {
+ return new TransactionCommitFailedException(
+ String.format("Commit of transaction %s failed", identifier), failure);