@Override
  public List<String> getAllDurableCqsFromServer(InternalPool pool) {
    return new ServerCQProxyImpl(pool).getAllDurableCqsFromServer();
  }
Let cq listeners know that they are connected or disconnected
geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/CqServiceImpl.java