@Test public void testCommit() throws Exception { final ListenableFuture<Void> commit = cohort.commit(); verify(history).onTransactionComplete(transaction.getTransaction().getIdentifier()); assertNull(getWithTimeout(commit)); }
@Override public ListenableFuture<Void> commit() { complete(); return VOID_FUTURE; }
DirectTransactionCommitCohort extends AbstractTransactionCommitCohort { @Override public ListenableFuture<Void> commit() { complete(); return VOID_FUTURE; } }
DirectTransactionCommitCohort extends AbstractTransactionCommitCohort { @Override public ListenableFuture<Void> commit() { complete(); return VOID_FUTURE; } DirectTransactionCommitCohort(final AbstractClientHistory parent, final TransactionIdentifier txId,
        final AbstractProxyTransaction proxy); }
DirectTransactionCommitCohort extends AbstractTransactionCommitCohort { @Override public ListenableFuture<Void> commit() { complete(); return VOID_FUTURE; } DirectTransactionCommitCohort(final AbstractClientHistory parent, final TransactionIdentifier txId,
        final AbstractProxyTransaction proxy); @Override ListenableFuture<Boolean> canCommit(); @Override ListenableFuture<Void> preCommit(); @Override ListenableFuture<Void> abort(); @Override ListenableFuture<Void> commit(); }
DirectTransactionCommitCohort extends AbstractTransactionCommitCohort { @Override public ListenableFuture<Void> commit() { complete(); return VOID_FUTURE; } DirectTransactionCommitCohort(final AbstractClientHistory parent, final TransactionIdentifier txId,
        final AbstractProxyTransaction proxy); @Override ListenableFuture<Boolean> canCommit(); @Override ListenableFuture<Void> preCommit(); @Override ListenableFuture<Void> abort(); @Override ListenableFuture<Void> commit();  }