From 78e6efce14037373d9dc646fce8129e24e35a3c6 Mon Sep 17 00:00:00 2001 From: heavyrian2012 Date: Wed, 30 Oct 2024 19:00:35 +0800 Subject: [PATCH] =?UTF-8?q?=E9=80=8F=E4=BC=A0=E6=B6=88=E6=81=AF=E9=9C=80?= =?UTF-8?q?=E8=A6=81=E5=B8=A6=E4=B8=8A=E6=97=B6=E9=97=B4=E6=88=B3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/io/moquette/spi/impl/MessagesPublisher.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 64df68cb..30d67746 100755 --- a/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java +++ b/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java @@ -451,7 +451,7 @@ public class MessagesPublisher { WFCMessage.Message message = m_messagesStore.getMessage(messageHead); if (message != null) { - message = message.toBuilder().setMessageId(0).setServerTimestamp(0).build(); + message = message.toBuilder().setMessageId(0).build(); for (String user : receivers) { Collection sessions = m_sessionsStore.sessionForUser(user);