From 7d1843f48513b246fcf4e081a5e3057ccaad4704 Mon Sep 17 00:00:00 2001 From: Gordon <1432970085@qq.com> Date: Sat, 21 May 2022 14:19:45 +0800 Subject: [PATCH] log change --- .../msg_transfer/logic/online_history_msg_handler.go | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/internal/msg_transfer/logic/online_history_msg_handler.go b/internal/msg_transfer/logic/online_history_msg_handler.go index 007896bd4..905d39b10 100644 --- a/internal/msg_transfer/logic/online_history_msg_handler.go +++ b/internal/msg_transfer/logic/online_history_msg_handler.go @@ -129,9 +129,15 @@ func (och *OnlineHistoryConsumerHandler) Run(channelID int) { singleMsgSuccessCountMutex.Lock() singleMsgSuccessCount += uint64(len(storageMsgList)) singleMsgSuccessCountMutex.Unlock() - for _, v := range pushMsgList { - sendMessageToPush(v, msgChannelValue.userID) - } + //go func(push,storage []*pbMsg.MsgDataToMQ) { + // for _, v := range storage { + // sendMessageToPush(v, msgChannelValue.userID) + // } + // for _, x := range utils.DifferenceString() { + // sendMessageToPush(v, msgChannelValue.userID) + // } + // + //}(pushMsgList,storageMsgList) } }