protected synchronized boolean trackMessage(StreamingReplyMessage m) {
        msgsProcessed++;

        if (m.isLastMessage()) {
          numMsgs = m.getMessageNumber() + 1;
        }
        if (logger.isDebugEnabled()) {
          logger.debug(
              "Streaming Message Tracking Status: Processor id: {}; Sender: {}; Messages Processed: {}; NumMsgs: {}",
              getProcessorId(), m.getSender(), msgsProcessed, numMsgs);
        }

        // this.numMsgs starts out as zero and gets initialized
        // only when we get a lastMsg true.
        // Since we increment msgsProcessed, the following condition
        // cannot be true until sometime after we've received the
        // lastMsg, and signals that all messages have been processed
        return msgsProcessed == numMsgs;
      }
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