fixed "nil returned" error

This commit is contained in:
marvzhang
2020-01-10 18:42:37 +08:00
parent 95083bc47c
commit 09cef0a10a

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()