@Override
    public void memberDeparted(DistributionManager distributionManager,
        InternalDistributedMember id, boolean crashed) {
      if (id != null && waitingOnMember(id)) {
        failedMembers.add(id);
        memberDepartedMessage =
            String.format(
                "Streaming reply processor got memberDeparted event for < %s > crashed, %s",
                id, crashed);
      }
      super.memberDeparted(distributionManager, id, crashed);
    }
Return true if this is the very last reply msg to process for this member
geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/StreamingPartitionOperation.java