@Override
protected TransactionIdentifier nextIdentifier() {
- return TransactionIdentifier.create(getMemberName(), TX_COUNTER.getAndIncrement(), null);
+ return TransactionIdentifier.create(getMemberName(), TX_COUNTER.getAndIncrement());
}
@Override
}
@Override
- protected Future<PrimaryShardInfo> findPrimaryShard(final String shardName) {
+ protected Future<PrimaryShardInfo> findPrimaryShard(final String shardName, TransactionIdentifier txId) {
return getActorContext().findPrimaryShardAsync(shardName);
}
DOMStoreTransactionChain createTransactionChain() {
return new TransactionChainProxy(this);
}
+
+ @Override
+ protected void onTransactionContextCreated(TransactionIdentifier transactionId) {
+ }
}