From 7a9506f61658577f5e5f10f76e0f4a50f226e943 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Mon, 27 Feb 2023 12:47:18 +0800 Subject: [PATCH] modify msg --- internal/msg_transfer/logic/modify_msg_handler.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/msg_transfer/logic/modify_msg_handler.go b/internal/msg_transfer/logic/modify_msg_handler.go index 30086c9dc..6bb4f9313 100644 --- a/internal/msg_transfer/logic/modify_msg_handler.go +++ b/internal/msg_transfer/logic/modify_msg_handler.go @@ -92,6 +92,7 @@ func (mmc *ModifyMsgConsumerHandler) ModifyMsg(cMsg *sarama.ConsumerMessage, msg msg = msgs[0] index = indexes[msg.Seq] } + msg.IsReact = true if err := db.DB.ReplaceMsgByIndex(notification.SourceID, msg, index); err != nil { log.NewError(msgDataToMQ.OperationID, "ReplaceMsgByIndex failed", notification.SourceID, *msg) }