+ private BatchedModifications prepareBatchedModifications(String transactionID,
+ MutableCompositeModification modification,
+ boolean doCommitOnReady) {
+ final BatchedModifications batchedModifications = new BatchedModifications(transactionID, CURRENT_VERSION, null);
+ batchedModifications.addModification(modification);
+ batchedModifications.setReady(true);
+ batchedModifications.setDoCommitOnReady(doCommitOnReady);
+ batchedModifications.setTotalMessagesSent(1);
+ return batchedModifications;
+ }
+
+
+ public static NormalizedNode<?,?> readStore(final TestActorRef<? extends Shard> shard, final YangInstanceIdentifier id)
+ throws ExecutionException, InterruptedException {
+ return shard.underlyingActor().getDataStore().readNode(id).orNull();
+ }
+
+ public static NormalizedNode<?,?> readStore(final DataTree store, final YangInstanceIdentifier id) {
+ return store.takeSnapshot().readNode(id).orNull();