docs: private void processPartitionReplyMsg(PartitionReplyMsg msg) {
  
          if (analyzerProxy == null) {
              return;
          }
  
          switch (msg.getMsgType()) {
              case PARTITION_COLLECTOR_DATA:
                  Serializable collectorData = deserializeCollectorData(msg.getCollectorData());
                  logger.finer("Analyze collector data: " + collectorData);
                  analyzerProxy.analyzeCollectorData(collectorData);
                  break;
  
              case PARTITION_FINAL_STATUS:
                  logger.fine("Calling analyzeStatus(): " + msg);
                  analyzerProxy.analyzeStatus(msg.getBatchStatus(), msg.getExitStatus());
                  break;
          }
      }