}
}
- @Override
- void purge(final Runnable callback) {
- openTransaction.purge(callback);
- }
-
private void handleTransactionPreCommit(final TransactionPreCommitRequest request,
final RequestEnvelope envelope, final long now) throws RequestException {
readyCohort.preCommit(new FutureCallback<DataTreeCandidate>() {