From 22708caaaa6a1b237f0ccb60a1e46329da9c550f Mon Sep 17 00:00:00 2001 From: heavyrian2012 Date: Tue, 22 Feb 2022 15:29:53 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=8D=E8=83=BD=E5=8F=8D=E5=A4=8D=E6=92=A4?= =?UTF-8?q?=E5=9B=9E=E6=B6=88=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/io/moquette/persistence/MemoryMessagesStore.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 6fe0d8ff..f8dec125 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -2077,6 +2077,10 @@ public class MemoryMessagesStore implements IMessagesStore { if (!canRecall) { return ErrorCode.ERROR_CODE_NOT_RIGHT; } + + if(message.getContent().getType() == 80) { + return ErrorCode.ERROR_CODE_SUCCESS; + } JSONObject json = new JSONObject(); json.put("s", message.getFromUser());