broker/BytesMetricsHandlerc: code formatter used

broker/src/main/java/io/moquette/server/netty/metrics/BytesMetricsHandler.java

@@ -13,6 +13,7 @@
  *
  * You may elect to redistribute this code under either of these licenses.
  */
+
 package io.moquette.server.netty.metrics;
 
 import io.netty.buffer.ByteBuf;
@@ -30,7 +31,7 @@ public class BytesMetricsHandler extends ChannelDuplexHandler {
     private BytesMetricsCollector m_collector;
 
     public BytesMetricsHandler(BytesMetricsCollector collector) {
-          m_collector = collector;
+        m_collector = collector;
     }
 
     @Override
@@ -44,21 +45,19 @@ public class BytesMetricsHandler extends ChannelDuplexHandler {
     @Override
     public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
         BytesMetrics metrics = ctx.channel().attr(ATTR_KEY_METRICS).get();
-        metrics.incrementRead(((ByteBuf)msg).readableBytes());
+        metrics.incrementRead(((ByteBuf) msg).readableBytes());
         ctx.fireChannelRead(msg);
     }
 
     @Override
     public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
         BytesMetrics metrics = ctx.channel().attr(ATTR_KEY_METRICS).get();
-        metrics.incrementWrote(((ByteBuf)msg).writableBytes());
+        metrics.incrementWrote(((ByteBuf) msg).writableBytes());
         ctx.write(msg, promise);
     }
 
-
     @Override
-    public void close(ChannelHandlerContext ctx,
-                      ChannelPromise promise) throws Exception {
+    public void close(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception {
         BytesMetrics metrics = ctx.channel().attr(ATTR_KEY_METRICS).get();
         m_collector.sumReadBytes(metrics.readBytes());
         m_collector.sumWroteBytes(metrics.wroteBytes());