From 250b0ccebee11b0ea239e3379057098052664f01 Mon Sep 17 00:00:00 2001
From: heavyrian2012 <heavyrain.lee@wildfirehat.cn>
Date: Mon, 23 May 2022 14:20:30 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3server=20api=E6=92=A4?=
 =?UTF-8?q?=E5=9B=9E=E5=8D=95=E8=81=8A=E6=B6=88=E6=81=AF=E6=97=A0=E6=B3=95?=
 =?UTF-8?q?=E6=92=A4=E5=9B=9E=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/io/moquette/imhandler/RecallMessageHandler.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/broker/src/main/java/io/moquette/imhandler/RecallMessageHandler.java b/broker/src/main/java/io/moquette/imhandler/RecallMessageHandler.java
index 5484936ed..79197d1b8 100644
--- a/broker/src/main/java/io/moquette/imhandler/RecallMessageHandler.java
+++ b/broker/src/main/java/io/moquette/imhandler/RecallMessageHandler.java
@@ -34,7 +34,7 @@ public ErrorCode action(ByteBuf ackPayload, String clientID, String fromUser, Pr
             return ErrorCode.ERROR_CODE_NOT_EXIST;
         }
 
-        publish(fromUser, clientID, message, requestSourceType);
+        publish(message.getFromUser(), clientID, message, requestSourceType);
 
         return errorCode;
     }