diff --git a/backend/services/rpc.go b/backend/services/rpc.go index 9b6a5b74..1743a8d2 100644 --- a/backend/services/rpc.go +++ b/backend/services/rpc.go @@ -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()