- /**
- * Return the {@link ActorContext} associated with this object.
- *
- * @return An actor context instance.
- */
- @Nonnull ActorContext getActorContext() {
- return actorContext;
+ private Future<Object> initiateCommit(final boolean immediate,
+ final Optional<SortedSet<String>> participatingShardNames) {
+ if (operationError != null) {
+ return Futures.failed(operationError);
+ }
+
+ final ReadyLocalTransaction message = new ReadyLocalTransaction(transaction.getIdentifier(),
+ modification, immediate, participatingShardNames);
+ return actorContext.executeOperationAsync(leader, message, actorContext.getTransactionCommitOperationTimeout());