inna/think-rabbit-queue

ThinkPHP 的 RabbitMQ 队列。

维护者

详情

github.com/fitv/think-rabbit-queue

源代码

问题

安装: 4

依赖: 0

建议者: 0

安全: 0

星标: 0

关注者: 1

分支: 0

1.0.2 2021-09-15 03:37 UTC

Requires

MIT 5d2ee4e6b14accaf8d9f6c8dbef52c15e591e1d6

  • mamx <mx.ma.woop@qq.com>

queuerabbitmqthinkphp

This package is auto-updated.

Last update: 2024-09-29 05:56:43 UTC

README

ThinkPHP 5 的 RabbitMQ 队列。

安装

$ composer require inna/think-rabbit-queue

使用

<?php

use Inna\RabbitQueue\Job;
use Inna\RabbitQueue\ShouldQueue;

class CancelOrderJob extends Job implements ShouldQueue
{
    public $order;
    
    public function __construct($order)
    {
        $this->order = $order;
    }

    public function handle() 
    {
        if ($this->order->shouldCancel()) {
            $this->order->cancel();
        }
    }
}
<?php

use Carbon\Carbon;
use Inna\RabbitQueue\Queue;

$order = Order::find(1);

$job = (new CancelOrderJob($order))->delay(Carbon::now()->addDays(7));

$job->dispatch();
<?php

use Inna\RabbitQueue\Queue;

Queue::consume();