diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/ActiveUserCounter.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/ActiveUserCounter.java index 83b958573..e6c5676a0 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/ActiveUserCounter.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/ActiveUserCounter.java @@ -18,6 +18,7 @@ package org.whispersystems.textsecuregcm.storage; import com.codahale.metrics.Gauge; import com.codahale.metrics.MetricRegistry; +import com.codahale.metrics.ScheduledReporter; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import io.dropwizard.metrics.MetricsFactory; @@ -91,7 +92,9 @@ public class ActiveUserCounter extends AccountDatabaseCrawlerListener { } for (ReporterFactory reporterFactory : metricsFactory.getReporters()) { - reporterFactory.build(metrics).report(); + try (final ScheduledReporter reporter = reporterFactory.build(metrics)) { + reporter.report(); + } } } diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/RegistrationLockVersionCounter.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/RegistrationLockVersionCounter.java index e47c5706c..b7d28f07e 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/RegistrationLockVersionCounter.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/RegistrationLockVersionCounter.java @@ -1,6 +1,7 @@ package org.whispersystems.textsecuregcm.storage; import com.codahale.metrics.MetricRegistry; +import com.codahale.metrics.ScheduledReporter; import io.dropwizard.metrics.MetricsFactory; import io.dropwizard.metrics.ReporterFactory; import io.lettuce.core.KeyValue; @@ -82,7 +83,9 @@ public class RegistrationLockVersionCounter extends AccountDatabaseCrawlerListen } for (final ReporterFactory reporterFactory : metricsFactory.getReporters()) { - reporterFactory.build(metricRegistry).report(); + try (final ScheduledReporter reporter = reporterFactory.build(metricRegistry)) { + reporter.report(); + } } } }