void checkCqStatOnServer(VM server, final String durableClientId, final String cqName,
      final int expectedNumber) {
    server.invoke(
        "Check ha queued cq stats for durable client " + durableClientId + " cq: " + cqName,
        new CacheSerializableRunnable() {
          @Override
          public void run2() throws CacheException {

            final CacheClientNotifier ccnInstance = CacheClientNotifier.getInstance();
            final CacheClientProxy clientProxy = ccnInstance.getClientProxy(durableClientId);
            ClientProxyMembershipID proxyId = clientProxy.getProxyID();
            CqService cqService = ((InternalCache) getCache()).getCqService();
            cqService.start();
            final CqQueryImpl cqQuery =
                (CqQueryImpl) cqService.getClientCqFromServer(proxyId, cqName);

            // Wait until we get the expected number of events or until 10 seconds are up
            await()
                .until(() -> cqQuery.getVsdStats().getNumHAQueuedEvents() == expectedNumber);

            assertThat(expectedNumber).isEqualTo(cqQuery.getVsdStats().getNumHAQueuedEvents());
          }
        });
  }
Returns the durable client proxy's HARegionQueue region name. This method is accessed via
reflection on a server VM.

@return the durable client proxy's HARegionQueue region name
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/DurableClientTestBase.java