From b6949ead26f557734ef1e946715aced2e3d7e1f9 Mon Sep 17 00:00:00 2001 From: Andreas Mager Date: Wed, 1 Feb 2017 15:43:14 +0100 Subject: [PATCH] broker/MQTTMessageLogger: code formatter used --- .../moquette/server/netty/metrics/MQTTMessageLogger.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/broker/src/main/java/io/moquette/server/netty/metrics/MQTTMessageLogger.java b/broker/src/main/java/io/moquette/server/netty/metrics/MQTTMessageLogger.java index 236e74ab..c4e905d9 100644 --- a/broker/src/main/java/io/moquette/server/netty/metrics/MQTTMessageLogger.java +++ b/broker/src/main/java/io/moquette/server/netty/metrics/MQTTMessageLogger.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.moquette.server.netty.NettyUtils; @@ -23,7 +24,6 @@ import io.netty.channel.ChannelPromise; import io.netty.handler.codec.mqtt.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; - import static io.moquette.spi.impl.Utils.messageId; /** @@ -54,7 +54,11 @@ public class MQTTMessageLogger extends ChannelDuplexHandler { break; case SUBSCRIBE: MqttSubscribeMessage subscribe = (MqttSubscribeMessage) msg; - LOG.info("{} SUBSCRIBE <{}> to topics {}", direction, clientID, subscribe.payload().topicSubscriptions()); + LOG.info( + "{} SUBSCRIBE <{}> to topics {}", + direction, + clientID, + subscribe.payload().topicSubscriptions()); break; case UNSUBSCRIBE: MqttUnsubscribeMessage unsubscribe = (MqttUnsubscribeMessage) msg;