IM/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2026-05-09 11:35:59 +08:00
Code Issues Packages Projects Releases Wiki Activity

mongo consumer

Browse Source
This commit is contained in:
wangchuxiao
2023-05-10 18:18:30 +08:00
parent 651c904aff
commit 2043abb24b
2 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/msgtransfer/init.go
-1
View File
@@ -46,7 +46,6 @@ func StartTransfer(prometheusPort int) error {
client, err := openKeeper.NewClient(config.Config.Zookeeper.ZkAddr, config.Config.Zookeeper.Schema,
openKeeper.WithFreq(time.Hour), openKeeper.WithRoundRobin(), openKeeper.WithUserNameAndPassword(config.Config.Zookeeper.UserName,
config.Config.Zookeeper.Password), openKeeper.WithTimeout(10))
if err != nil {
return err
}