diff --git a/broker/src/main/java/io/moquette/server/netty/MoquetteIdleTimeoutHandler.java b/broker/src/main/java/io/moquette/server/netty/MoquetteIdleTimeoutHandler.java index 69378b62..3e93a9e7 100644 --- a/broker/src/main/java/io/moquette/server/netty/MoquetteIdleTimeoutHandler.java +++ b/broker/src/main/java/io/moquette/server/netty/MoquetteIdleTimeoutHandler.java @@ -13,11 +13,11 @@ * * You may elect to redistribute this code under either of these licenses. */ + package io.moquette.server.netty; import org.slf4j.Logger; import org.slf4j.LoggerFactory; - import io.netty.channel.ChannelDuplexHandler; import io.netty.channel.ChannelHandler.Sharable; import io.netty.channel.ChannelHandlerContext; @@ -26,24 +26,26 @@ import io.netty.handler.timeout.IdleStateEvent; @Sharable class MoquetteIdleTimeoutHandler extends ChannelDuplexHandler { - - private static final Logger LOG = LoggerFactory.getLogger(MoquetteIdleTimeoutHandler.class); - + + private static final Logger LOG = LoggerFactory.getLogger(MoquetteIdleTimeoutHandler.class); + @Override public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception { if (evt instanceof IdleStateEvent) { IdleState e = ((IdleStateEvent) evt).state(); if (e == IdleState.ALL_IDLE) { - LOG.info("Firing channel inactive event. MqttClientId = {}.", NettyUtils.clientID(ctx.channel())); - //fire a channelInactive to trigger publish of Will + LOG.info("Firing channel inactive event. MqttClientId = {}.", NettyUtils.clientID(ctx.channel())); + // fire a channelInactive to trigger publish of Will ctx.fireChannelInactive(); ctx.close(); } } else { - if (LOG.isDebugEnabled()) { - LOG.debug("Firing Netty event. MqttClientId = {}, eventClass = {}.", NettyUtils.clientID(ctx.channel()), - evt.getClass().getName()); - } + if (LOG.isDebugEnabled()) { + LOG.debug( + "Firing Netty event. MqttClientId = {}, eventClass = {}.", + NettyUtils.clientID(ctx.channel()), + evt.getClass().getName()); + } super.userEventTriggered(ctx, evt); } }