public static void assertAllQueuesEmpty() {
    for (final CacheServer server : cacheServer.getCacheServers()) {
      for (final CacheClientProxy cacheClientProxy : ((CacheServerImpl) server).getAcceptor()
          .getCacheClientNotifier()
          .getClientProxies()) {
        int qsize = cacheClientProxy.getQueueSize();
        assertTrue("Queue size expected to be zero but is " + qsize, qsize == 0);
      }
    }
  }
Assert all queues are empty to aid later assertion for listener event counts.
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/ClientConflationDistributedTest.java