Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-27 17:24:44 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

优化消息队列持久化日志

Browse Source
This commit is contained in:
orgin
2022-12-01 14:19:02 +08:00
parent b1fee9bc57
commit 76c8541b34
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
sysservice/messagequeueservice/MongoPersist.go
View File

@@ -141,7 +141,7 @@ func (mp *MongoPersist) persistTopicData(collectionName string, topicData []Topi
_, err := s.Collection(mp.dbName, collectionName).InsertMany(ctx, documents) _, err := s.Collection(mp.dbName, collectionName).InsertMany(ctx, documents)
if err != nil { if err != nil {
log.SError("PersistTopicData InsertMany fail,collect name is ", collectionName) log.SError("PersistTopicData InsertMany fail,collect name is ", collectionName," error:",err.Error())
//失败最大重试数量 //失败最大重试数量
return retryCount >= mp.retryCount return retryCount >= mp.retryCount