public void waitForChannelState(DistributedMember member, Map channelState)
      throws InterruptedException {
    if (Thread.interrupted()) {
      throw new InterruptedException();
    }
    TCPConduit tc = conduit;
    if (tc != null) {
      tc.waitForThreadOwnedOrderedConnectionState(member, channelState);
    }
  }
wait for the given connections to process the number of messages associated with the connection
in the given map
geode-core/src/main/java/org/apache/geode/distributed/internal/direct/DirectChannel.java