@Test
public void testMultipleRegistrationsAtOnePrefix() throws Exception {

    initEmptyDatastores();
    for (int i = 0; i < 10; i++) {
        LOG.debug("Round {}", i);
        final DistributedShardRegistration reg1 = waitOnAsyncTask(leaderShardFactory.createDistributedShard(
                TEST_ID, Lists.newArrayList(AbstractTest.MEMBER_NAME)),
                DistributedShardedDOMDataTree.SHARD_FUTURE_TIMEOUT_DURATION);
        leaderTestKit.waitUntilLeader(leaderDistributedDataStore.getActorUtils(),
                ClusterUtils.getCleanShardName(TestModel.TEST_PATH));
        assertNotNull(findLocalShard(leaderDistributedDataStore.getActorUtils(),
                ClusterUtils.getCleanShardName(TestModel.TEST_PATH)));
        waitOnAsyncTask(reg1.close(), DistributedShardedDOMDataTree.SHARD_FUTURE_TIMEOUT_DURATION);
        waitUntilShardIsDown(leaderDistributedDataStore.getActorUtils(),
                ClusterUtils.getCleanShardName(TestModel.TEST_PATH));
    }
}