Merge pull request #444 from crawlab-team/develop

fixed "nil returned" error
This commit is contained in:
Marvin Zhang
2020-01-10 18:44:43 +08:00
committed by GitHub

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