private int processCqs(Message clientMessage, int startMessagePart, int numCqParts,
      MessageType messageType, Object key, Object value) {
    return processCqs(clientMessage, startMessagePart, numCqParts, messageType, key, value, null,
        null);
  }
Processes message to invoke CQ listeners.
geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientUpdater.java