From a156a1d0849ce350c0480a9a1ad8f7c9782d4cb1 Mon Sep 17 00:00:00 2001 From: Andreas Mager Date: Wed, 1 Feb 2017 15:21:48 +0100 Subject: [PATCH] broker/HazelcastListener: code formatter used --- .../java/io/moquette/server/HazelcastListener.java | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/broker/src/main/java/io/moquette/server/HazelcastListener.java b/broker/src/main/java/io/moquette/server/HazelcastListener.java index d0b6aa50..03dff1b9 100644 --- a/broker/src/main/java/io/moquette/server/HazelcastListener.java +++ b/broker/src/main/java/io/moquette/server/HazelcastListener.java @@ -1,3 +1,4 @@ + package io.moquette.server; import com.hazelcast.core.Message; @@ -13,11 +14,12 @@ import org.slf4j.LoggerFactory; * Created by mackristof on 28/05/2016. */ public class HazelcastListener implements MessageListener { + private static final Logger LOG = LoggerFactory.getLogger(HazelcastListener.class); private final Server server; - public HazelcastListener(Server server){ + public HazelcastListener(Server server) { this.server = server; } @@ -26,9 +28,12 @@ public class HazelcastListener implements MessageListener { try { if (!msg.getPublishingMember().equals(server.getHazelcastInstance().getCluster().getLocalMember())) { HazelcastMsg hzMsg = msg.getMessageObject(); - LOG.info("{} received from hazelcast for topic {} message: {}", hzMsg.getClientId(), - hzMsg.getTopic(), hzMsg.getPayload()); - //TODO pass forward this information in somehow publishMessage.setLocal(false); + LOG.info( + "{} received from hazelcast for topic {} message: {}", + hzMsg.getClientId(), + hzMsg.getTopic(), + hzMsg.getPayload()); + // TODO pass forward this information in somehow publishMessage.setLocal(false); MqttQoS qos = MqttQoS.valueOf(hzMsg.getQos()); MqttFixedHeader fixedHeader = new MqttFixedHeader(MqttMessageType.PUBLISH, false, qos, false, 0);