diff --git a/netty_parser/src/main/java/io/moquette/parser/proto/messages/PublishMessage.java b/netty_parser/src/main/java/io/moquette/parser/proto/messages/PublishMessage.java index cbe5ec2b..6afd83ab 100644 --- a/netty_parser/src/main/java/io/moquette/parser/proto/messages/PublishMessage.java +++ b/netty_parser/src/main/java/io/moquette/parser/proto/messages/PublishMessage.java @@ -42,7 +42,7 @@ public class PublishMessage extends MessageIDMessage { } public ByteBuffer getPayload() { - return m_payload; + return m_payload.duplicate(); } public void setPayload(ByteBuffer payload) {