private static List<String> getAllDurableCqsFromServer() throws CqException {
    QueryService queryService = getPool().getQueryService();
    return queryService.getAllDurableCqsFromServer();
  }
Tests situation where a client is trying to reconnect while a cq is being drained
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/DurableClientCQDUnitTest.java