private void scheduleIncomingMessage(DistributionMessage message) {
    /*
     * Potential race condition between starting up and getting other distribution manager ids -- DM
     * will only be initialized upto the point at which it called startThreads
     */
    waitUntilReadyForMessages();
    message.schedule(this);
  }
Schedule a given message appropriately, depending upon its executor kind.
geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterDistributionManager.java