protected boolean trackMessage(StreamingReplyMessage m) {
      Status status;
      synchronized (this) {
        status = (Status) statusMap.get(m.getSender());
        if (status == null) {
          status = new Status();
          statusMap.put(m.getSender(), status);
        }
      }
      return status.trackMessage(m);
    }
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