This commit is contained in:
wangchuxiao 2023-04-28 10:26:27 +08:00
parent 6da0c38927
commit 45ad252a44

View File

@ -117,7 +117,7 @@ func (och *OnlineHistoryRedisConsumerHandler) getPushStorageMsgList(aggregationI
notificationMsg := proto.Clone(v.message).(*pbMsg.MsgDataToMQ) notificationMsg := proto.Clone(v.message).(*pbMsg.MsgDataToMQ)
if options.IsSendMsg() { 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) storageMsgList = append(storageMsgList, v.message)
} }
if isStorage(notificationMsg) { if isStorage(notificationMsg) {