@Override
  protected void process(DistributionMessage msg, boolean warn) {
    if (msg instanceof ReplyMessage) {
      InternalDistributedSystem.getLogger().info(String.format("%s",
          "processing message with return value " + ((ReplyMessage) msg).getReturnValue()));
      results.put(msg.getSender(), (T) ((ReplyMessage) msg).getReturnValue());
    }
    super.process(msg, warn);
  }
This reply processor collects all of the exceptions/results from the ReplyMessages it receives
geode-core/src/main/java/org/apache/geode/distributed/internal/CollectingReplyProcessor.java