Merge remote-tracking branch 'origin/tuoyun' into tuoyun

3 years ago · b2ae3b4fee
parent 5b9e5f904b 7d1843f485
commit b2ae3b4fee
1 changed files with 9 additions and 3 deletions
--- 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)

 				}
 			}