fixed "nil returned" error

This commit is contained in:
marvzhang
2020-01-10 18:42:37 +08:00
parent a974d636c9
commit e5cd929a2a

View File

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