diff --git a/broker/src/main/java/io/moquette/interception/messages/InterceptAcknowledgedMessage.java b/broker/src/main/java/io/moquette/interception/messages/InterceptAcknowledgedMessage.java index 6cf31590..f2ce2305 100644 --- a/broker/src/main/java/io/moquette/interception/messages/InterceptAcknowledgedMessage.java +++ b/broker/src/main/java/io/moquette/interception/messages/InterceptAcknowledgedMessage.java @@ -1,27 +1,29 @@ + package io.moquette.interception.messages; import static io.moquette.spi.IMessagesStore.StoredMessage; public class InterceptAcknowledgedMessage implements InterceptMessage { - final private StoredMessage msg; - private final String username; - private final String topic; - - public InterceptAcknowledgedMessage( final StoredMessage msg, final String topic, final String username) { - this.msg = msg; - this.username = username; - this.topic = topic; - } - - public StoredMessage getMsg() { - return msg; - } - public String getUsername() { - return username; - } + final private StoredMessage msg; + private final String username; + private final String topic; - public String getTopic() { - return topic; - } + public InterceptAcknowledgedMessage(final StoredMessage msg, final String topic, final String username) { + this.msg = msg; + this.username = username; + this.topic = topic; + } + + public StoredMessage getMsg() { + return msg; + } + + public String getUsername() { + return username; + } + + public String getTopic() { + return topic; + } }