@Test
public void testAbortWithFailure() throws Exception {

    ThreePhaseCommitCohortProxy proxy = new ThreePhaseCommitCohortProxy(actorUtils, Arrays.asList(
            newCohortInfo(new CohortActor.Builder(tx).expectAbort(new RuntimeException("mock")))), tx);
    // The exception should not get propagated.
    verifySuccessfulFuture(proxy.abort());
    verifyCohortActors();
}