@Test
public void testAbort() throws Exception {

    ThreePhaseCommitCohortProxy proxy = new ThreePhaseCommitCohortProxy(actorUtils, Arrays.asList(
            newCohortInfo(new CohortActor.Builder(tx).expectAbort(
                    AbortTransactionReply.instance(CURRENT_VERSION)))), tx);
    verifySuccessfulFuture(proxy.abort());
    verifyCohortActors();
}