synchronized void addClientCq(ClientProxyMembershipID clientId, String cqName,
      MessageType cqEvent) {
    if (_clientCqs == null) {
      _clientCqs = new ClientCqConcurrentMap();
      _hasCqs = true;
    }
    CqNameToOp cqInfo = _clientCqs.get(clientId);
    if (cqInfo == null) {
      cqInfo = new CqNameToOpSingleEntry(cqName, cqEvent);
      _clientCqs.put(clientId, cqInfo);
    } else if (!cqInfo.isFull()) {
      cqInfo.add(cqName, cqEvent);
    } else {
      cqInfo = new CqNameToOpHashMap((CqNameToOpSingleEntry) cqInfo);
      cqInfo.add(cqName, cqEvent);
      _clientCqs.put(clientId, cqInfo);
    }
  }
Returns the cqs for the given client.
geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ClientUpdateMessageImpl.java