README

安装

composer require dilab/queueable

使用

任务 & 队列

创建一个任务

class SendEmailJob implements JobContract
{
    public function handle(Payload $payload)
    {
        return 'Sending an email to user ' . $payload->get('name');
    }

}

创建一个队列

$driver = new InMemoryDriver();

$queue = new Queue('email', $driver);

入队一个任务

$queue->push(
    new SendEmailJob(),
    new Payload(['name' => 'Xu'])
);

工作者

创建一个工作者实例

$worker = new Worker($queue);

放置工作者进行工作

$worker->work($maxTries = 5, $sleepSecs = 5);

如果需要，您可以设置一个 PSR-3 日志记录器

$worker->setLogger($psr3Logger);

回调

beforeFetchJob: 在尝试从队列中获取任务之前被调用

$worker->attach('heartbeat', function () use ($queueName) {
    // do something useful
});

beforeCompleteJob: 在任务完成之前被调用

$worker->attach('beforeCompleteJob', function () {
    // do something useful
});

afterCompleteJob: 在任务完成后被调用

$worker->attach('afterCompleteJob', function () {
    // do something useful
});

onError: 在处理任务失败时被调用

$worker->attach('onError', function ($failedJob, $message, $trace) {
    // send an email
});

当前驱动程序

AWS SQS

备注

在开发此包时的一些通用备注

驱动程序与消息（原始数据，通常是数组格式）一起工作
队列将消息转换为任务
任务与消息一起工作
工作者与任务 & 队列对象一起工作

dilab / queueable

维护者

详细信息

README

安装

使用

任务 & 队列

工作者

回调

当前驱动程序

备注