Fix input/process/output buffer usage metrics

Refs d92c3f0 Fixes #1784
Graylog2 · Feb 9, 2016 · e9b2a0f · e9b2a0f
1 parent d451116
commit e9b2a0f
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 3 deletions.
diff --git a/graylog2-server/src/main/java/org/graylog2/buffers/OutputBuffer.java b/graylog2-server/src/main/java/org/graylog2/buffers/OutputBuffer.java
@@ -58,7 +58,12 @@ public OutputBuffer(MetricRegistry metricRegistry,
         this.ringBufferSize = ringSize;
         this.incomingMessages = metricRegistry.meter(name(OutputBuffer.class, "incomingMessages"));
 
-        safelyRegister(metricRegistry, GlobalMetricNames.OUTPUT_BUFFER_USAGE, (Gauge<Long>) this::getUsage);
+        safelyRegister(metricRegistry, GlobalMetricNames.OUTPUT_BUFFER_USAGE, new Gauge<Long>() {
+            @Override
+            public Long getValue() {
+                return OutputBuffer.this.getUsage();
+            }
+        });
         safelyRegister(metricRegistry, GlobalMetricNames.OUTPUT_BUFFER_SIZE, constantGauge(ringBufferSize));
 
         final ThreadFactory threadFactory = threadFactory(metricRegistry);

diff --git a/graylog2-server/src/main/java/org/graylog2/shared/buffers/InputBufferImpl.java b/graylog2-server/src/main/java/org/graylog2/shared/buffers/InputBufferImpl.java
@@ -82,7 +82,12 @@ public InputBufferImpl(MetricRegistry metricRegistry,
         ringBuffer = disruptor.start();
 
         incomingMessages = metricRegistry.meter(name(InputBufferImpl.class, "incomingMessages"));
-        safelyRegister(metricRegistry, GlobalMetricNames.INPUT_BUFFER_USAGE, (Gauge<Long>) this::getUsage);
+        safelyRegister(metricRegistry, GlobalMetricNames.INPUT_BUFFER_USAGE, new Gauge<Long>() {
+            @Override
+            public Long getValue() {
+                return InputBufferImpl.this.getUsage();
+            }
+        });
         safelyRegister(metricRegistry, GlobalMetricNames.INPUT_BUFFER_SIZE, constantGauge(ringBuffer.getBufferSize()));
 
         LOG.info("Initialized {} with ring size <{}> and wait strategy <{}>, running {} parallel message handlers.",

diff --git a/graylog2-server/src/main/java/org/graylog2/shared/buffers/ProcessBuffer.java b/graylog2-server/src/main/java/org/graylog2/shared/buffers/ProcessBuffer.java
@@ -64,7 +64,12 @@ public ProcessBuffer(MetricRegistry metricRegistry,
 
         final Timer parseTime = metricRegistry.timer(name(ProcessBuffer.class, "parseTime"));
         final Timer decodeTime = metricRegistry.timer(name(ProcessBuffer.class, "decodeTime"));
-        MetricUtils.safelyRegister(metricRegistry, GlobalMetricNames.PROCESS_BUFFER_USAGE, (Gauge<Long>) this::getUsage);
+        MetricUtils.safelyRegister(metricRegistry, GlobalMetricNames.PROCESS_BUFFER_USAGE, new Gauge<Long>() {
+            @Override
+            public Long getValue() {
+                return ProcessBuffer.this.getUsage();
+            }
+        });
         safelyRegister(metricRegistry, GlobalMetricNames.PROCESS_BUFFER_SIZE, constantGauge(ringBufferSize));
 
         final WaitStrategy waitStrategy = getWaitStrategy(waitStrategyName, "processor_wait_strategy");