throws InterruptedException, ExecutionException {
RpcResult<TransactionStatus> rpcResult = future.get();
assertTrue(rpcResult.isSuccessful());
assertEquals(TransactionStatus.COMMITED, rpcResult.getResult());
}
throws InterruptedException, ExecutionException {
RpcResult<TransactionStatus> rpcResult = future.get();
assertTrue(rpcResult.isSuccessful());
assertEquals(TransactionStatus.COMMITED, rpcResult.getResult());
}