From f75e140ddf6ffd9d6b8659f288ae91f4141e3eae Mon Sep 17 00:00:00 2001 From: Andreas Mager Date: Wed, 1 Feb 2017 15:42:39 +0100 Subject: [PATCH] broker/MeassageMetricsHandler: code formatter used --- .../server/netty/metrics/MessageMetricsHandler.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/broker/src/main/java/io/moquette/server/netty/metrics/MessageMetricsHandler.java b/broker/src/main/java/io/moquette/server/netty/metrics/MessageMetricsHandler.java index 7786a5af..dc8f102a 100644 --- a/broker/src/main/java/io/moquette/server/netty/metrics/MessageMetricsHandler.java +++ b/broker/src/main/java/io/moquette/server/netty/metrics/MessageMetricsHandler.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.channel.Channel; @@ -29,7 +30,7 @@ public class MessageMetricsHandler extends ChannelDuplexHandler { private MessageMetricsCollector m_collector; public MessageMetricsHandler(MessageMetricsCollector collector) { - m_collector = collector; + m_collector = collector; } @Override @@ -54,10 +55,8 @@ public class MessageMetricsHandler extends ChannelDuplexHandler { ctx.write(msg, promise); } - @Override - public void close(ChannelHandlerContext ctx, - ChannelPromise promise) throws Exception { + public void close(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception { MessageMetrics metrics = ctx.channel().attr(ATTR_KEY_METRICS).get(); m_collector.sumReadMessages(metrics.messagesRead()); m_collector.sumWroteMessages(metrics.messagesWrote());