- private static void assertCommitSuccessful(final ListenableFuture<RpcResult<TransactionStatus>> future)
- throws InterruptedException, ExecutionException {
- RpcResult<TransactionStatus> rpcResult = future.get();
- assertTrue(rpcResult.isSuccessful());
- assertEquals(TransactionStatus.COMMITED, rpcResult.getResult());
+ private static void assertCommitSuccessful(
+ final ListenableFuture<Void> future) throws InterruptedException, ExecutionException {
+ future.get();