diff --git a/internal/msg_transfer/logic/online_history_msg_handler.go b/internal/msg_transfer/logic/online_history_msg_handler.go index 5e0b9a520..5c2668976 100644 --- a/internal/msg_transfer/logic/online_history_msg_handler.go +++ b/internal/msg_transfer/logic/online_history_msg_handler.go @@ -108,7 +108,7 @@ func (och *OnlineHistoryConsumerHandler) Run(channelID int) { for _, v := range msgList { log.Debug(triggerID, "msg come to storage center", v.String()) if v.MsgData == nil { - log.NewWarn(triggerID, "msg come to storage center nil", v.String(), v.OperationID) + log.NewWarn(triggerID, "msg come to storage center nil", v.String(), v.OperationID, msgChannelValue.userID) continue } isHistory := utils.GetSwitchFromOptions(v.MsgData.Options, constant.IsHistory) @@ -238,7 +238,10 @@ func (och *OnlineHistoryConsumerHandler) MessagesDistributionHandle() { if len(v) >= 0 { hashCode := getHashCode(userID) channelID := hashCode % ChannelNum - log.Debug(triggerID, "generate channelID", hashCode, channelID, userID) + log.Debug(triggerID, "generate channelID", hashCode, channelID, userID, len(v)) + for _, y := range v { + log.Debug(triggerID, "single user slice is ", y.String()) + } //go func(cID uint32, userID string, messages []*pbMsg.MsgDataToMQ) { och.chArrays[channelID] <- Cmd2Value{Cmd: UserMessages, Value: MsgChannelValue{userID: userID, msgList: v, triggerID: triggerID}} //}(channelID, userID, v)