private static void checkNumberOfClientProxies(int expected) {
    int current = getNumberOfClientProxies();
    int tries = 1;
    while (expected != current && tries++ < 60) {
      try {
        Thread.sleep(250);
      } catch (InterruptedException ignore) {
        Thread.currentThread().interrupt(); // reset bit
      }
      current = getNumberOfClientProxies();
    }
    assertEquals(expected, current);
  }
This test does the following for cq registration with initial result set through pool when
<b>failover</b>(<b>cq registration</b>):<br>
1)Verifies when primary goes down, cq registration happen <br>
2)Verifies create entry for region in map stored in CacheCleintProxy <br>
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/DeltaToRegionRelationCQRegistrationDUnitTest.java