From d0fdf55db4ba86f554f46c357a0286c16c39f069 Mon Sep 17 00:00:00 2001 From: heavyrian2012 Date: Mon, 29 Jul 2024 11:45:35 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BE=A4=E7=BB=84=E8=A7=A3=E6=95=A3=E5=90=8E?= =?UTF-8?q?=E6=92=A4=E5=9B=9E=E5=A4=B1=E8=B4=A5=E7=9A=84=E9=94=99=E8=AF=AF?= =?UTF-8?q?=E7=A0=81=E5=BA=94=E8=AF=A5=E6=98=AF=E4=B8=8D=E5=AD=98=E5=9C=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/io/moquette/persistence/MemoryMessagesStore.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 62cdbac4..1dd402ad 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -2421,7 +2421,8 @@ public class MemoryMessagesStore implements IMessagesStore { WFCMessage.GroupInfo groupInfo = groupMap.get(message.getConversation().getTarget()); if (groupInfo == null) { - return ErrorCode.ERROR_CODE_RECALL_TIME_EXPIRED; + LOG.info("recall message failure, group {} not exist", message.getConversation().getTarget()); + return ErrorCode.ERROR_CODE_NOT_EXIST; } if (operatorId.equals(groupInfo.getOwner())) { if(operatorId.equals(message.getFromUser())) {