diff --git a/broker/src/main/java/io/moquette/interception/messages/InterceptPublishMessage.java b/broker/src/main/java/io/moquette/interception/messages/InterceptPublishMessage.java index cbf7b606..1235ab97 100644 --- a/broker/src/main/java/io/moquette/interception/messages/InterceptPublishMessage.java +++ b/broker/src/main/java/io/moquette/interception/messages/InterceptPublishMessage.java @@ -1,3 +1,4 @@ + package io.moquette.interception.messages; import io.netty.buffer.ByteBuf; @@ -7,10 +8,11 @@ import io.netty.handler.codec.mqtt.MqttPublishMessage; * @author Wagner Macedo */ public class InterceptPublishMessage extends InterceptAbstractMessage { + private final MqttPublishMessage msg; private final String clientID; private final String username; - + public InterceptPublishMessage(MqttPublishMessage msg, String clientID, String username) { super(msg); this.msg = msg; @@ -30,7 +32,7 @@ public class InterceptPublishMessage extends InterceptAbstractMessage { return clientID; } - public String getUsername() { - return username; - } + public String getUsername() { + return username; + } }