vendor/codeages/biz-framework/src/Queue/JobFailer.php

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

<?php

namespace Codeages\Biz\Framework\Queue;

class JobFailer
{
    protected $dao;

    public function __construct($dao)
    {
        $this->dao = $dao;
    }

    public function log(Job $job, $queue, $message)
    {
        $failedJob = array(
            'queue' => $queue,
            'body' => $job->getBody(),
            'class' => $job->getMetadata('class'),
            'timeout' => $job->getMetadata('timeout', 0),
            'priority' => $job->getMetadata('priority', 0),
            'reason' => $message,
        );

        $this->dao->create($failedJob);
    }
}