diff --git a/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java b/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java index 92a82eb1..64df68cb 100755 --- a/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java +++ b/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java @@ -451,6 +451,7 @@ public class MessagesPublisher { WFCMessage.Message message = m_messagesStore.getMessage(messageHead); if (message != null) { + message = message.toBuilder().setMessageId(0).setServerTimestamp(0).build(); for (String user : receivers) { Collection sessions = m_sessionsStore.sessionForUser(user);