@Test
public void testAbort() throws Exception {

    final ListenableFuture<Void> abort = cohort.abort();
    verify(history).onTransactionComplete(TRANSACTION_ID);
    assertNull(getWithTimeout(abort));
}