From 45ad252a440520d7740df6438a31b2fbc5b31937 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 28 Apr 2023 10:26:27 +0800 Subject: [PATCH] msg --- internal/msgtransfer/online_history_msg_handler.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/msgtransfer/online_history_msg_handler.go b/internal/msgtransfer/online_history_msg_handler.go index 2401de4d5..a0520c33d 100644 --- a/internal/msgtransfer/online_history_msg_handler.go +++ b/internal/msgtransfer/online_history_msg_handler.go @@ -117,7 +117,7 @@ func (och *OnlineHistoryRedisConsumerHandler) getPushStorageMsgList(aggregationI notificationMsg := proto.Clone(v.message).(*pbMsg.MsgDataToMQ) if options.IsSendMsg() { // 消息 - v.message.MsgData.Options = utils.WithOptions(utils.Options(v.message.MsgData.Options), utils.WithNotification(false)) + v.message.MsgData.Options = utils.WithOptions(utils.Options(v.message.MsgData.Options), utils.WithNotification(false), utils.WithSendMsg(false)) storageMsgList = append(storageMsgList, v.message) } if isStorage(notificationMsg) {