private void closeCQsforDurableClient(String durableClientId) {
    server1VM.invoke("Close cq for durable client", new CacheSerializableRunnable() {
      @Override
      public void run2() throws CacheException {

        final CacheClientNotifier ccnInstance = CacheClientNotifier.getInstance();

        try {
          ccnInstance.closeClientCq(durableClientId, "All");
          ccnInstance.closeClientCq(durableClientId, "GreaterThan5");
          ccnInstance.closeClientCq(durableClientId, "LessThan5");
        } catch (CqException e) {
          fail("failed", e);
        }
      }
    });
  }
Test functionality to close the cq and drain all events from the ha queue from the server This
draining should remove all events due to no interest registered Continues to publish afterwards
to verify that stats are correct
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/DurableClientCQDUnitTest.java