vendor/codeages/biz-framework/src/Provider/QueueServiceProvider.php

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

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

<?php

namespace Codeages\Biz\Framework\Provider;

use Pimple\Container;
use Pimple\ServiceProviderInterface;
use Codeages\Biz\Framework\Queue\Driver\SyncQueue;
use Codeages\Biz\Framework\Queue\JobFailer;
use Codeages\Biz\Framework\Queue\Command\WorkerCommand;
use Codeages\Biz\Framework\Queue\Command\TableCommand;

class QueueServiceProvider implements ServiceProviderInterface
{
    public function register(Container $biz)
    {
        $biz['autoload.aliases']['Queue'] = 'Codeages\Biz\Framework\Queue';
        $biz['console.commands'][] = function () use ($biz) {
            return new WorkerCommand($biz);
        };
        $biz['console.commands'][] = function () use ($biz) {
            return new TableCommand($biz);
        };

        $biz['queue.failer'] = function ($biz) {
            return new JobFailer($biz->dao('Queue:FailedJobDao'));
        };

        $biz['queue.connection.default'] = function ($biz) {
            return new SyncQueue('default', $biz, $biz['queue.failer']);
        };
    }
}