mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-04-23 18:00:32 +08:00
channelNum
This commit is contained in:
parent
948e5a2dde
commit
c83e816bda
@ -154,7 +154,6 @@ 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)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user