consumer consume async

3 years ago · 579a6f7181
parent a9d85c3957
commit 579a6f7181
1 changed files with 1 additions and 1 deletions
--- a/src/msg_transfer/logic/history_msg_handler.go
+++ b/src/msg_transfer/logic/history_msg_handler.go
@ -81,7 +81,7 @@ func (mc *HistoryConsumerHandler) handleChatWs2Mongo(msg []byte, msgKey string)
 		if msgKey == pbSaveData.RecvID {
 			pbSaveData.Options = pbData.Options
 			pbSaveData.OfflineInfo = pbData.OfflineInfo
-			sendMessageToPush(&pbSaveData)
+			go sendMessageToPush(&pbSaveData)
 			log.NewInfo(pbSaveData.OperationID, "sendMessageToPush cost time ", utils.GetCurrentTimestampBySecond()-time)
 		}