class MetricCollectors {

  public static double currentConsumptionRate() {
    return collectorMap.values().stream()
        .mapToDouble(MetricCollector::currentMessageConsumptionRate)
        .sum();
  }

}