|
|
@ -155,6 +155,7 @@ func (och *OnlineHistoryConsumerHandler) Run(channelID int) {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
func (och *OnlineHistoryConsumerHandler) SendMessageToMongoCH(userID string, triggerID string, messages []*pbMsg.MsgDataToMQ, lastSeq uint64) {
|
|
|
|
func (och *OnlineHistoryConsumerHandler) SendMessageToMongoCH(userID string, triggerID string, messages []*pbMsg.MsgDataToMQ, lastSeq uint64) {
|
|
|
|
|
|
|
|
return
|
|
|
|
hashCode := getHashCode(userID)
|
|
|
|
hashCode := getHashCode(userID)
|
|
|
|
channelID := hashCode % ChannelNum
|
|
|
|
channelID := hashCode % ChannelNum
|
|
|
|
log.Debug(triggerID, "generate channelID", hashCode, channelID, userID)
|
|
|
|
log.Debug(triggerID, "generate channelID", hashCode, channelID, userID)
|
|
|
|