docs: protected void sendCollectorDataPartitionReplyMsg(Serializable data) {
  
  	    if (logger.isLoggable(Level.FINE)) {
  	        logger.fine("Sending collector partition data: " + data + " to analyzer queue: " + getPartitionReplyQueue());
  	    }
  		
  		PartitionReplyMsg msg = new PartitionReplyMsg( PartitionReplyMsgType.PARTITION_COLLECTOR_DATA )
  			                                        .setCollectorData(serializeToByteArray(data));
  		getPartitionReplyQueue().add(msg);
  		    
  		
  	}