+ acquireOperation();
+ return (LocalThreePhaseCommitCohort) getWriteDelegate().ready();
+ }
+
+ @SuppressWarnings({ "unchecked", "rawtypes" })
+ private <T extends Future> T completeOperation(final ActorContext actorContext, final T operationFuture) {
+ operationFuture.onComplete(getLimiter(), actorContext.getClientDispatcher());
+ return operationFuture;