+ final String shardName = ClusterUtils.getCleanShardName(TEST_ID.getRootIdentifier());
+ LOG.debug("Creating distributed datastore client for shard {}", shardName);
+
+ final ActorContext actorContext = leaderDistributedDataStore.getActorContext();
+ final Props distributedDataStoreClientProps =
+ SimpleDataStoreClientActor.props(actorContext.getCurrentMemberName(),
+ "Shard-" + shardName, actorContext, shardName);
+
+ final ActorRef clientActor = leaderSystem.actorOf(distributedDataStoreClientProps);
+ final DataStoreClient distributedDataStoreClient = SimpleDataStoreClientActor
+ .getDistributedDataStoreClient(clientActor, 30, TimeUnit.SECONDS);
+
+ final ClientLocalHistory localHistory = distributedDataStoreClient.createLocalHistory();
+ final ClientTransaction tx2 = localHistory.createTransaction();
+ final CheckedFuture<Optional<NormalizedNode<?, ?>>,
+ org.opendaylight.mdsal.common.api.ReadFailedException> read =
+ tx2.read(YangInstanceIdentifier.EMPTY);
+
+ final Optional<NormalizedNode<?, ?>> optional = read.checkedGet();
+ tx2.abort();
+ localHistory.close();
+