@Override
    protected void process(ClusterDistributionManager dm) {
      SearchLoadAndWriteProcessor processor = null;
      processor = (SearchLoadAndWriteProcessor) getProcessorKeeper().retrieve(processorId);
      if (processor == null) {
        if (logger.isDebugEnabled()) {
          logger.debug("NetWriteReplyMessage() SearchLoadAndWriteProcessor no longer exists");
        }
        return;
      }
      processor.incomingNetWriteReply(netWriteSucceeded, e, cacheWriterException);
    }
Invoked on the receiver - which, in this case, was the initiator of the
NetWriteRequestMessage. This concludes the net write request, by communicating an object
value.
geode-core/src/main/java/org/apache/geode/internal/cache/SearchLoadAndWriteProcessor.java