@Override
    protected synchronized void processException(DistributionMessage msg, ReplyException ex) {
      Throwable t = ex.getCause();
      if (t instanceof ForceReattemptException || t instanceof CacheClosedException) {
        if (logger.isDebugEnabled()) {
          logger.debug(
              "StreamingPartitionResponse received exception {} for member {} query retry required.",
              t, msg.getSender());
        }
        failedMembers.add(msg.getSender());
      } else {
        super.processException(msg, ex);
      }
    }
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