protected DistributionManager getDM() {
    return owner.getDM();
  }
wait for the given incoming connections to receive at least the associated number of messages
geode-core/src/main/java/org/apache/geode/internal/tcp/ConnectionTable.java