public void initializeMessageDispatcher() throws CacheException {
    try {
      if (logger.isDebugEnabled()) {
        logger.debug("{}: Initializing message dispatcher with capacity of {} entries", this,
            _maximumMessageCount);
      }
      String name = "Client Message Dispatcher for " + getProxyID().getDistributedMember()
          + (isDurable() ? " (" + getDurableId() + ")" : "");
      _messageDispatcher = createMessageDispatcher(name);
    } catch (final Exception ex) {
      _statistics.close();
      throw ex;
    }
  }
Initializes the message dispatcher thread. The <code>MessageDispatcher</code> processes the
message queue.
geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientProxy.java