protected void deliverMessage(Conflatable conflatable) {
    final ClientUpdateMessage clientMessage;
    if (conflatable instanceof HAEventWrapper) {
      clientMessage = ((HAEventWrapper) conflatable).getClientUpdateMessage();
    } else {
      clientMessage = (ClientUpdateMessage) conflatable;
    }

    _statistics.incMessagesReceived();

    // post process for single-user mode. We don't do post process for multi-user mode
    if (subject != null) {
      ThreadState state = securityService.bindSubject(subject);
      try {
        if (securityService.needPostProcess()) {
          Object oldValue = clientMessage.getValue();
          Object newValue = securityService.postProcess(clientMessage.getRegionName(),
              clientMessage.getKeyOfInterest(), oldValue, clientMessage.valueIsObject());
          clientMessage.setLatestValue(newValue);
        }
      } finally {
        if (state != null) {
          state.clear();
        }
      }
    }

    if (clientMessage.needsNoAuthorizationCheck() || postDeliverAuthCheckPassed(clientMessage)) {
      if (_messageDispatcher != null) {
        _messageDispatcher.enqueueMessage(conflatable);
      } else {
        _statistics.incMessagesFailedQueued();

        if (logger.isDebugEnabled()) {
          logger.debug(
              "Message was not added to the queue. Message dispatcher was null for proxy: " + this
                  + ". Event ID hash code: " + conflatable.hashCode() + "; System ID hash code: "
                  + System.identityHashCode(conflatable) + "; Conflatable details: " + conflatable);
        }
      }
    } else {
      if (logger.isDebugEnabled()) {
        logger.debug(
            "Message was not added to the queue. Event ID hash code: " + conflatable.hashCode()
                + "; System ID hash code: "
                + System.identityHashCode(conflatable) + "; Conflatable details: " + conflatable);
      }

      _statistics.incMessagesFailedQueued();
    }
  }
Delivers the message to the client representing this client proxy.
geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientProxy.java