mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-06-03 14:12:53 +08:00
log
This commit is contained in:
parent
06aae24dad
commit
b632a991b9
@ -238,6 +238,8 @@ func (och *OnlineHistoryConsumerHandler) MessagesDistributionHandle() {
|
||||
go func(cID uint32, userID string, messages []*pbMsg.MsgDataToMQ) {
|
||||
och.chArrays[cID] <- Cmd2Value{Cmd: UserMessages, Value: MsgChannelValue{userID: userID, msgList: messages}}
|
||||
}(channelID, userID, v)
|
||||
} else {
|
||||
log.NewWarn(operationID, "UserAggregationMsgs ", len(v), userID)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
Loading…
x
Reference in New Issue
Block a user