* Date: 8/6/14
*/
public class ShardReadTransaction extends ShardTransaction {
- private static final YangInstanceIdentifier DATASTORE_ROOT = YangInstanceIdentifier.builder().build();
-
private final AbstractShardDataTreeTransaction<?> transaction;
public ShardReadTransaction(AbstractShardDataTreeTransaction<?> transaction, ActorRef shardActor,
- ShardStats shardStats, String transactionID, short clientTxVersion) {
- super(shardActor, shardStats, transactionID, clientTxVersion);
+ ShardStats shardStats, String transactionID) {
+ super(shardActor, shardStats, transactionID);
this.transaction = transaction;
}
final ActorRef sender = getSender();
final ActorRef self = getSelf();
- final Optional<NormalizedNode<?, ?>> result = transaction.getSnapshot().readNode(DATASTORE_ROOT);
+ final Optional<NormalizedNode<?, ?>> result = transaction.getSnapshot().readNode(YangInstanceIdentifier.EMPTY);
byte[] serialized = SerializationUtils.serializeNormalizedNode(result.get());
sender.tell(new CaptureSnapshotReply(serialized), self);