broker/ClientNettyMQTTHandler: code formatter used

This commit is contained in:
Andreas Mager
2017-02-01 17:13:43 +01:00
parent 42dca4a42e
commit 324721e155
@@ -13,6 +13,7 @@
* *
* You may elect to redistribute this code under either of these licenses. * You may elect to redistribute this code under either of these licenses.
*/ */
package io.moquette.testclient; package io.moquette.testclient;
import io.moquette.server.netty.NettyMQTTHandler; import io.moquette.server.netty.NettyMQTTHandler;
@@ -29,25 +30,25 @@ import org.slf4j.LoggerFactory;
*/ */
@ChannelHandler.Sharable @ChannelHandler.Sharable
class ClientNettyMQTTHandler extends ChannelInboundHandlerAdapter { class ClientNettyMQTTHandler extends ChannelInboundHandlerAdapter {
private static final Logger LOG = LoggerFactory.getLogger(NettyMQTTHandler.class); private static final Logger LOG = LoggerFactory.getLogger(NettyMQTTHandler.class);
private Client m_client; private Client m_client;
@Override @Override
public void channelRead(ChannelHandlerContext ctx, Object message) { public void channelRead(ChannelHandlerContext ctx, Object message) {
MqttMessage msg = (MqttMessage) message; MqttMessage msg = (MqttMessage) message;
LOG.info("Received a message of type {}", msg.fixedHeader().messageType()); LOG.info("Received a message of type {}", msg.fixedHeader().messageType());
m_client.messageReceived(msg); m_client.messageReceived(msg);
} }
@Override @Override
public void channelInactive(ChannelHandlerContext ctx)throws Exception { public void channelInactive(ChannelHandlerContext ctx) throws Exception {
m_client.setConnectionLost(true); m_client.setConnectionLost(true);
ctx.close(/*false*/); ctx.close(/* false */);
} }
void setClient(Client client) { void setClient(Client client) {
m_client = client; m_client = client;
} }
} }