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);
transactions.remove(transaction.getIdentifier());
}
- void sendRequest(final long sequence, final TransactionRequest<?> request, final Consumer<Response<?, ?>> completer) {
- sendRequest(sequence, request, response -> {
+ void sendRequest(final TransactionRequest<?> request, final Consumer<Response<?, ?>> completer) {
+ sendRequest(request, response -> {
completer.accept(response);
return this;
});