modify msg

2 years ago · 7a9506f616
parent 36afd67a2c
commit 7a9506f616
1 changed files with 1 additions and 0 deletions
--- 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)
 					}