@Override
    public void process(DistributionMessage msg) {
      // If the reply is a region version vector, store it in our RVV field.
      if (msg instanceof ReplyMessage) {
        ReplyMessage reply = (ReplyMessage) msg;
        Object returnValue = reply.getReturnValue();
        if (returnValue instanceof RegionVersionVector) {
          returnRVV = (RegionVersionVector) returnValue;
          synchronized (endLock) {
            if (allMessagesReceived(true)) {
              super.process(msg);
            }
          }
          return;
        }
      }
      super.process(msg);
    }
whether the last chunk has been processed
geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/FetchEntriesMessage.java