Fix error after refactor

allegro · Aug 29, 2023 · 5f24e2d · 5f24e2d
1 parent 9b6389a
commit 5f24e2d
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/...l/allegro/tech/hermes/management/infrastructure/prometheus/PrometheusMetricsProvider.java b/...l/allegro/tech/hermes/management/infrastructure/prometheus/PrometheusMetricsProvider.java
@@ -1,5 +1,7 @@
 package pl.allegro.tech.hermes.management.infrastructure.prometheus;
 
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
 import pl.allegro.tech.hermes.api.SubscriptionName;
 import pl.allegro.tech.hermes.api.TopicName;
 import pl.allegro.tech.hermes.management.infrastructure.metrics.MonitoringMetricsContainer;
@@ -35,9 +37,11 @@ public PrometheusMetricsProvider(PrometheusClient prometheusClient, String consu
         this.prometheusClient = prometheusClient;
         this.consumersMetricsPrefix = consumersMetricsPrefix.isEmpty() ? "" : consumersMetricsPrefix + "_";
         this.frontendMetricsPrefix = frontendMetricsPrefix.isEmpty() ? "" : frontendMetricsPrefix + "_";
-        this.subscriptionMetricsToQuery = String.join("|", List.of(SUBSCRIPTION_DELIVERED, SUBSCRIPTION_TIMEOUTS,
+        this.subscriptionMetricsToQuery = Stream.of(SUBSCRIPTION_DELIVERED, SUBSCRIPTION_TIMEOUTS,
                         SUBSCRIPTION_THROUGHPUT, SUBSCRIPTION_OTHER_ERRORS, SUBSCRIPTION_BATCHES,
-                        SUBSCRIPTION_STATUS_CODES));
+                        SUBSCRIPTION_STATUS_CODES)
+                .map(this::consumerMetricName)
+                .collect(Collectors.joining("|"));
         this.topicMetricsToQuery = String.join("|", List.of(
                 frontendMetricName(TOPIC_RATE),
                 consumerMetricName(TOPIC_DELIVERY_RATE),