private final ActorContext actorContext;
private final ActorSelection actor;
- private final boolean isTxActorLocal;
private final short remoteTransactionVersion;
private final OperationLimiter limiter;
private int totalBatchedModificationsSent;
protected RemoteTransactionContext(TransactionIdentifier identifier, ActorSelection actor,
- ActorContext actorContext, boolean isTxActorLocal,
- short remoteTransactionVersion, OperationLimiter limiter) {
+ ActorContext actorContext, short remoteTransactionVersion, OperationLimiter limiter) {
super(identifier);
this.limiter = Preconditions.checkNotNull(limiter);
this.actor = actor;
this.actorContext = actorContext;
- this.isTxActorLocal = isTxActorLocal;
this.remoteTransactionVersion = remoteTransactionVersion;
}
}
protected Future<Object> executeOperationAsync(SerializableMessage msg) {
- return completeOperation(actorContext.executeOperationAsync(getActor(), isTxActorLocal ? msg : msg.toSerializable()));
+ return completeOperation(actorContext.executeOperationAsync(getActor(), msg.toSerializable()));
}
@Override
}
};
- Future<Object> future = executeOperationAsync(readCmd);
+ Future<Object> future = executeOperationAsync(readCmd.asVersion(remoteTransactionVersion));
future.onComplete(onComplete, actorContext.getClientDispatcher());
}