Я использую драйвер базы данных для постановки своих заданий в очередь. Мне нужно вызвать команду artisan из задания в очереди, и когда задание будет завершено, мне нужно удалить его из очереди. Это код моего контроллера, в который я добавляю задание в очередь.
dispatch((new SendNewsletter())->onQueue('newsletter'));
Это моя работа в очереди
<?php
namespace App\Jobs;
use App\Console\Commands\Newsletter;
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
class SendNewsletter implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
/**
* Create a new job instance.
*
* @return void
*/
public function __construct()
{
}
/**
* Execute the job.
*
* @return void
*/
public function handle()
{
app()->make(Newsletter::class)->handle();
}
}
Мне нужно вызвать команду мастеров App\Console\Commands\Newsletter.
и когда задание заканчивается, это должно удалить его из очереди. Это класс AppServiceProvider
/**
* Bootstrap any application services.
*
* @return void
*/
public function boot() {
Queue::after(function ($event) {
if ($event->job->queue == 'newsletter') {
$event->job->delete();
}
});
}
Задание правильно добавлено в очередь базы данных, и когда я запускаю php artisan queue:work, задание вызывается несколько раз до бесконечности. кажется, что обратный вызов Queue :: after никогда не вызывается. любая идея, что мне не хватает?
