anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

透传消息去掉消息id和时间戳，减少消息体大小

Browse Source
This commit is contained in:
heavyrian2012
2024-10-02 20:04:47 +08:00
parent 845e6ff8aa
commit dd1783d4ac
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java
+1
View File
@@ -451,6 +451,7 @@ public class MessagesPublisher {
WFCMessage.Message message = m_messagesStore.getMessage(messageHead); WFCMessage.Message message = m_messagesStore.getMessage(messageHead);
if (message != null) { if (message != null) {
message = message.toBuilder().setMessageId(0).setServerTimestamp(0).build();
for (String user : receivers) { for (String user : receivers) {
Collection<Session> sessions = m_sessionsStore.sessionForUser(user); Collection<Session> sessions = m_sessionsStore.sessionForUser(user);