concrete > fix metrics

Author: DC2-DanielKrueger

hivemq-edge/src/main/java/com/hivemq/protocols/ProtocolAdapterMetrics.java

@@ -5,26 +5,30 @@
 
 import javax.inject.Inject;
 import javax.inject.Singleton;
+import java.util.concurrent.atomic.AtomicInteger;
 
 import static com.hivemq.metrics.HiveMQMetrics.ADAPTERS_CURRENT;
 import static com.hivemq.metrics.HiveMQMetrics.PROTOCOL_ADAPTER_PREFIX;
 
 @Singleton
 public class ProtocolAdapterMetrics {
+
     private final @NotNull MetricRegistry metricRegistry;
+    private final AtomicInteger currentAdapters = new AtomicInteger();
 
     @Inject
     public ProtocolAdapterMetrics(final @NotNull MetricRegistry metricRegistry) {
         this.metricRegistry = metricRegistry;
+        metricRegistry.registerGauge(ADAPTERS_CURRENT.name(), currentAdapters::intValue);
     }
 
     public void increaseProtocolAdapterMetric(final @NotNull String protocolType) {
         metricRegistry.counter(PROTOCOL_ADAPTER_PREFIX + protocolType + ".current").inc();
-        metricRegistry.counter(ADAPTERS_CURRENT.name()).inc();
+        currentAdapters.incrementAndGet();
     }
 
     public void decreaseProtocolAdapterMetric(final @NotNull String protocolType) {
         metricRegistry.counter(PROTOCOL_ADAPTER_PREFIX + protocolType + ".current").dec();
-        metricRegistry.counter(ADAPTERS_CURRENT.name()).inc();
+        currentAdapters.decrementAndGet();
     }
 }