From 30da8c043d77225b731de33b6b090f7cc45c576c Mon Sep 17 00:00:00 2001 From: Andreas Mager Date: Wed, 1 Feb 2017 15:41:45 +0100 Subject: [PATCH] broker/MeassageMetricsCollector: code formatter used --- .../moquette/server/netty/metrics/MessageMetricsCollector.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/broker/src/main/java/io/moquette/server/netty/metrics/MessageMetricsCollector.java b/broker/src/main/java/io/moquette/server/netty/metrics/MessageMetricsCollector.java index ecca02b5..dfab4bbb 100644 --- a/broker/src/main/java/io/moquette/server/netty/metrics/MessageMetricsCollector.java +++ b/broker/src/main/java/io/moquette/server/netty/metrics/MessageMetricsCollector.java @@ -13,6 +13,7 @@ * * You may elect to redistribute this code under either of these licenses. */ + package io.moquette.server.netty.metrics; import java.util.concurrent.atomic.AtomicLong; @@ -21,6 +22,7 @@ import java.util.concurrent.atomic.AtomicLong; * Collects all the metrics from the various pipeline. */ public class MessageMetricsCollector { + private AtomicLong readMsgs = new AtomicLong(); private AtomicLong wroteMsgs = new AtomicLong();