From dd1783d4acdc9c1718005e9259c92cbe5160989e Mon Sep 17 00:00:00 2001
From: heavyrian2012 <heavyrain.lee@wildfirehat.cn>
Date: Wed, 2 Oct 2024 20:04:47 +0800
Subject: [PATCH] =?UTF-8?q?=E9=80=8F=E4=BC=A0=E6=B6=88=E6=81=AF=E5=8E=BB?=
 =?UTF-8?q?=E6=8E=89=E6=B6=88=E6=81=AFid=E5=92=8C=E6=97=B6=E9=97=B4?=
 =?UTF-8?q?=E6=88=B3=EF=BC=8C=E5=87=8F=E5=B0=91=E6=B6=88=E6=81=AF=E4=BD=93?=
 =?UTF-8?q?=E5=A4=A7=E5=B0=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java | 1 +
 1 file changed, 1 insertion(+)

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<Session> sessions = m_sessionsStore.sessionForUser(user);