修复rpc timeout 报错问题

This commit is contained in:
marvzhang
2020-01-10 15:16:34 +08:00
parent d124c6c96f
commit 65261a5797

View File

@@ -185,7 +185,7 @@ func InitRpcService() error {
}
// 获取获取消息队列信息
dataStr, err := database.RedisClient.BRPop(fmt.Sprintf("rpc:%s", node.Id.Hex()), 300)
dataStr, err := database.RedisClient.BRPop(fmt.Sprintf("rpc:%s", node.Id.Hex()), 0)
if err != nil {
log.Errorf(err.Error())
debug.PrintStack()