@Test
public void testGetBackendInfo() throws Exception {

    final CompletionStage<ShardBackendInfo> i = moduleShardBackendResolver.getBackendInfo(0L);
    contextProbe.expectMsgClass(ConnectClientRequest.class);
    final TestProbe backendProbe = new TestProbe(system, "backend");
    final ConnectClientSuccess msg = new ConnectClientSuccess(CLIENT_ID, 0L, backendProbe.ref(),
            Collections.emptyList(), dataTree, 3);
    contextProbe.reply(msg);
    final CompletionStage<ShardBackendInfo> stage = moduleShardBackendResolver.getBackendInfo(0L);
    final ShardBackendInfo shardBackendInfo = TestUtils.getWithTimeout(stage.toCompletableFuture());
    Assert.assertEquals(0L, shardBackendInfo.getCookie().longValue());
    Assert.assertEquals(dataTree, shardBackendInfo.getDataTree().get());
    Assert.assertEquals(DefaultShardStrategy.DEFAULT_SHARD, shardBackendInfo.getName());
}