Remove unused imports, raw types and some deprecated method calls..

broker/src/main/java/io/moquette/server/netty/AutoFlushHandler.java

@@ -17,7 +17,6 @@ package io.moquette.server.netty;
 
 import io.netty.channel.ChannelDuplexHandler;
 import io.netty.channel.ChannelHandlerContext;
-import io.netty.handler.timeout.IdleStateEvent;
 import io.netty.util.concurrent.EventExecutor;
 
 import java.util.concurrent.ScheduledFuture;

broker/src/main/java/io/moquette/server/netty/NettyAcceptor.java

@@ -38,7 +38,6 @@ import io.netty.handler.codec.http.HttpRequestDecoder;
 import io.netty.handler.codec.http.HttpResponseEncoder;
 import io.netty.handler.codec.http.HttpServerCodec;
 import io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame;
-import io.netty.handler.codec.http.websocketx.Utf8FrameValidator;
 import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
 import io.netty.handler.ssl.SslHandler;
 import io.netty.handler.timeout.IdleStateHandler;

broker/src/main/java/io/moquette/server/netty/NettyUtils.java

@@ -16,7 +16,6 @@
 package io.moquette.server.netty;
 
 import io.moquette.server.Constants;
-import io.moquette.spi.impl.ProtocolProcessor;
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.util.Attribute;

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

@@ -34,7 +34,7 @@ public class BytesMetricsHandler extends ChannelDuplexHandler {
 
     @Override
     public void channelActive(ChannelHandlerContext ctx) throws Exception {
-        Attribute<BytesMetrics> attr = ctx.attr(ATTR_KEY_METRICS);
+        Attribute<BytesMetrics> attr = ctx.channel().attr(ATTR_KEY_METRICS);
         attr.set(new BytesMetrics());
 
         super.channelActive(ctx);
@@ -42,14 +42,14 @@ public class BytesMetricsHandler extends ChannelDuplexHandler {
 
     @Override
     public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
-        BytesMetrics metrics = ctx.attr(ATTR_KEY_METRICS).get();
+        BytesMetrics metrics = ctx.channel().attr(ATTR_KEY_METRICS).get();
         metrics.incrementRead(((ByteBuf)msg).readableBytes());
         ctx.fireChannelRead(msg);
     }
 
     @Override
     public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
-        BytesMetrics metrics = ctx.attr(ATTR_KEY_METRICS).get();
+        BytesMetrics metrics = ctx.channel().attr(ATTR_KEY_METRICS).get();
         metrics.incrementWrote(((ByteBuf)msg).writableBytes());
         ctx.write(msg, promise);
     }
@@ -58,7 +58,7 @@ public class BytesMetricsHandler extends ChannelDuplexHandler {
     @Override
     public void close(ChannelHandlerContext ctx,
                       ChannelPromise promise) throws Exception {
-        BytesMetrics metrics = ctx.attr(ATTR_KEY_METRICS).get();
+        BytesMetrics metrics = ctx.channel().attr(ATTR_KEY_METRICS).get();
         m_collector.sumReadBytes(metrics.readBytes());
         m_collector.sumWroteBytes(metrics.wroteBytes());
         super.close(ctx, promise);

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

@@ -33,7 +33,7 @@ public class MessageMetricsHandler extends ChannelDuplexHandler {
 
     @Override
     public void channelActive(ChannelHandlerContext ctx) throws Exception {
-        Attribute<MessageMetrics> attr = ctx.attr(ATTR_KEY_METRICS);
+        Attribute<MessageMetrics> attr = ctx.channel().attr(ATTR_KEY_METRICS);
         attr.set(new MessageMetrics());
 
         super.channelActive(ctx);
@@ -41,14 +41,14 @@ public class MessageMetricsHandler extends ChannelDuplexHandler {
 
     @Override
     public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
-        MessageMetrics metrics = ctx.attr(ATTR_KEY_METRICS).get();
+        MessageMetrics metrics = ctx.channel().attr(ATTR_KEY_METRICS).get();
         metrics.incrementRead(1);
         ctx.fireChannelRead(msg);
     }
 
     @Override
     public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
-        MessageMetrics metrics = ctx.attr(ATTR_KEY_METRICS).get();
+        MessageMetrics metrics = ctx.channel().attr(ATTR_KEY_METRICS).get();
         metrics.incrementWrote(1);
         ctx.write(msg, promise);
     }
@@ -57,7 +57,7 @@ public class MessageMetricsHandler extends ChannelDuplexHandler {
     @Override
     public void close(ChannelHandlerContext ctx,
                       ChannelPromise promise) throws Exception {
-        MessageMetrics metrics = ctx.attr(ATTR_KEY_METRICS).get();
+        MessageMetrics metrics = ctx.channel().attr(ATTR_KEY_METRICS).get();
         m_collector.sumReadMessages(metrics.messagesRead());
         m_collector.sumWroteMessages(metrics.messagesWrote());
         super.close(ctx, promise);