private LocalThreePhaseCommitCohort ready() {
logModificationCount();
- LocalThreePhaseCommitCohort cohort = readySupport.onTransactionReady(getWriteDelegate());
- if (operationError != null) {
- cohort.setOperationError(operationError);
- }
- return cohort;
+ return readySupport.onTransactionReady(getWriteDelegate(), operationError);
}
@Override