void checkHAQueueSize(VM server, final String durableClientId, final int expectedNumber,
      final int remaining) {
    server.invoke("Check ha queued size for durable client " + durableClientId,
        new CacheSerializableRunnable() {
          @Override
          public void run2() throws CacheException {

            final CacheClientNotifier ccnInstance = CacheClientNotifier.getInstance();
            final CacheClientProxy clientProxy = ccnInstance.getClientProxy(durableClientId);

            // Wait until we get the expected number of events or until 10 seconds are up
            await().untilAsserted(
                () -> assertThat(clientProxy.getQueueSizeStat()).isIn(expectedNumber, remaining));
          }
        });
  }
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