this.parent = parent;
}
- public String getTransactionChainId() {
- return getHistoryId().toString();
- }
-
@Override
public DOMStoreReadTransaction newReadOnlyTransaction() {
currentState.checkReady();
getActorContext().broadcast(new Function<Short, Object>() {
@Override
public Object apply(Short version) {
- return new CloseTransactionChain(getHistoryId().toString(), version).toSerializable();
+ return new CloseTransactionChain(getHistoryId(), version).toSerializable();
}
- });
+ }, CloseTransactionChain.class);
}
private TransactionProxy allocateWriteTransaction(final TransactionType type) {
LOG.debug("Tx: {} - waiting for ready futures with pending Tx {}", txId, previousTransactionId);
} else {
previousTransactionId = "";
- LOG.debug("Waiting for ready futures on chain {}", getTransactionChainId());
+ LOG.debug("Waiting for ready futures on chain {}", getHistoryId());
}
previous = combineFutureWithPossiblePriorReadOnlyTxFutures(previous, txId);