public void removeFailedSenders(Set notReceivedMembers) {
      for (final Object notReceivedMember : notReceivedMembers) {
        removeMember((InternalDistributedMember) notReceivedMember, true);
      }
    }
Overridden to wait for messages being currently processed: This situation can come about if a
member departs while we are still processing data from that member
geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/StreamingPartitionOperation.java