@Override
      public void run2() throws CacheException {
        // Find the proxy
        checkNumberOfClientProxies(2);
      }
Test functionality to close the cq and drain all events from the ha queue from the server Two
durable clients, one will have a cq be closed, the other should be unaffected
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/DurableClientCQDUnitTest.java