DistributedDataStoreClientBehavior(final ClientActorContext context, final ActorContext actorContext) {
super(context);
- resolver = new ModuleShardBackendResolver(actorContext);
+ resolver = new ModuleShardBackendResolver(context.getIdentifier(), actorContext);
singleHistory = new SingleClientHistory(this, new LocalHistoryIdentifier(getIdentifier(), 0));
}
public ClientTransaction createTransaction() {
final TransactionIdentifier txId = new TransactionIdentifier(singleHistory.getIdentifier(),
nextTransactionId.getAndIncrement());
- final ClientTransaction tx = new ClientTransaction(this, singleHistory, txId);
+ final ClientTransaction tx = new ClientTransaction(singleHistory, txId);
LOG.debug("{}: creating a new transaction {}", persistenceId(), tx);
return returnIfOperational(transactions, txId, tx, aborted);