super(client, identifier);
}
+ @Override
+ ClientSnapshot doCreateSnapshot() {
+ final TransactionIdentifier txId = new TransactionIdentifier(getIdentifier(), nextTx());
+ LOG.debug("{}: creating a new snapshot {}", this, txId);
+
+ return new ClientSnapshot(this, txId);
+ }
+
@Override
ClientTransaction doCreateTransaction() {
final TransactionIdentifier txId = new TransactionIdentifier(getIdentifier(), nextTx());
@Override
ProxyHistory createHistoryProxy(final LocalHistoryIdentifier historyId,
final AbstractClientConnection<ShardBackendInfo> connection) {
- return ProxyHistory.createSingle(connection, historyId);
+ return ProxyHistory.createSingle(this, connection, historyId);
}
}