private void handleIncomingDMsg(Message message) {
    stats.incReceivedMessages(1L);
    stats.incReceivedBytes(message.getBytesRead());
    stats.incMessageChannelTime(message.resetTimestamp());

    if (logger.isDebugEnabled()) {
      logger.debug("Received message '{}' from <{}>", message, message.getSender());
    }
    scheduleIncomingMessage((DistributionMessage) message);
  }
Process an incoming distribution message. This includes scheduling it correctly based on the
message's nioPriority (executor type)
geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterDistributionManager.java