@Test(timeout = 10000)
public void testLocalShardNotFound() {

    final TestKit kit = new TestKit(getSystem());
    ActorUtils actorUtils = new ActorUtils(getSystem(), kit.getRef(), mock(ClusterWrapper.class),
        mock(Configuration.class));
    final YangInstanceIdentifier path = YangInstanceIdentifier.of(TestModel.TEST_QNAME);
    final DataTreeChangeListenerProxy<DOMDataTreeChangeListener> proxy = new DataTreeChangeListenerProxy<>(
            actorUtils, mockListener, path);
    new Thread(() -> proxy.init("shard-1")).start();
    Duration timeout = Duration.ofSeconds(5);
    FindLocalShard findLocalShard = kit.expectMsgClass(timeout, FindLocalShard.class);
    assertEquals("getShardName", "shard-1", findLocalShard.getShardName());
    kit.reply(new LocalShardNotFound("shard-1"));
    kit.expectNoMessage(Duration.ofSeconds(1));
    proxy.close();
}