concurrent consumption of messages

3 years ago · 4d2f3fa219
parent c7e0a57b50
commit 4d2f3fa219
1 changed files with 1 additions and 1 deletions
--- a/pkg/common/db/batch_insert_chat.go
+++ b/pkg/common/db/batch_insert_chat.go
@ -31,7 +31,7 @@ func (d *DataBases) BatchInsertChat(userID string, msgList []*pbMsg.MsgDataToMQ,
 	if currentMaxSeq < uint64(GetSingleGocMsgNum()) {
 		remain = uint64(GetSingleGocMsgNum()-1) - (currentMaxSeq % uint64(GetSingleGocMsgNum()))
 	} else {
-		remain = uint64(GetSingleGocMsgNum()) - (currentMaxSeq % uint64(GetSingleGocMsgNum()))
+		remain = uint64(GetSingleGocMsgNum()) - ((currentMaxSeq - 4999) % uint64(GetSingleGocMsgNum()))
 	}
 	insertCounter := uint64(0)
 	msgListToMongo := make([]MsgInfo, 0)