Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-04 06:54:45 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

优化消息队列服务日志

Browse Source
This commit is contained in:
orgin
2022-11-29 17:25:34 +08:00
parent 284d43dc71
commit b1fee9bc57
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
sysservice/messagequeueservice/MongoPersist.go
View File

@@ -398,8 +398,7 @@ func (mp *MongoPersist) PersistIndex(topic string, customerId string, index uint
ctx, cancel := s.GetDefaultContext() ctx, cancel := s.GetDefaultContext()
defer cancel() defer cancel()
ret, err := s.Collection(mp.dbName, CustomerCollectName).UpdateOne(ctx, condition, updata, UpdateOptionsOpts...) _, err := s.Collection(mp.dbName, CustomerCollectName).UpdateOne(ctx, condition, updata, UpdateOptionsOpts...)
fmt.Println(ret)
if err != nil { if err != nil {
log.SError("PersistIndex fail :", err.Error()) log.SError("PersistIndex fail :", err.Error())
} }