src/Worker.php
protected function process(JobInterface $job, Job $obj)
    {
        try {
            $obj->setJob($job);

            $this->handleWithObj($obj);

            $job->delete();
        } catch (\Exception $e) {
            if ($job->attempts() < $obj->tries) { //小于最大尝试次数 release
                $job->release();
            } else { //超过了放到失败中
                $job->bury();

                $this->logProcessError($e);
            }
        }
    }
protected function process(JobInterface $job, Job $obj)
    {
        try {
            $obj->setJob($job);

            $this->handleWithObj($obj);

            $job->delete();
        } catch (\Exception $e) {
            if ($job->attempts() < $obj->tries) { //小于最大尝试次数 release
                $job->release();
            } else { //超过了放到失败中
                $job->bury();

                $this->logProcessError($e);
            }
        }
    }
!!! 对 队列的 bury 增加监控，防止失败未处理的 job 过多
@param JobInterface $job 队列里的每个 job 对象
@param Job $obj job 中反序列化后具体的实例对象 应用开发者定义的 job