return new ClientTransaction(this, new TransactionIdentifier(getIdentifier(), nextTx()));
}
+ @Override
+ void onTransactionAbort(final TransactionIdentifier txId) {
+ final State local = state();
+ if (local == State.TX_OPEN) {
+ updateState(local, State.IDLE);
+ }
+
+ super.onTransactionAbort(txId);
+ }
+
@Override
AbstractTransactionCommitCohort onTransactionReady(final TransactionIdentifier txId,
final AbstractTransactionCommitCohort cohort) {