public void validationForFailOver() {
    assertTrue(" primary server is not detected ", primary != -1);
    if (primary == PORT1) {
      server.invoke(DeltaToRegionRelationCQRegistrationDUnitTest::validationOnServer);
      server.invoke(DeltaToRegionRelationCQRegistrationDUnitTest::stopCacheServer);
      server2.invoke(DeltaToRegionRelationCQRegistrationDUnitTest::validationOnServer);
    } else {
      server2.invoke(DeltaToRegionRelationCQRegistrationDUnitTest::validationOnServer);
      server2.invoke(DeltaToRegionRelationCQRegistrationDUnitTest::stopCacheServer);
      server.invoke(DeltaToRegionRelationCQRegistrationDUnitTest::validationOnServer);
    }
  }
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