файле
app/Providers/AppServiceProvider.php
<?php
namespace App\Providers;
use Illuminate\Support\Facades\Queue;
use Illuminate\Support\ServiceProvider;
use Illuminate\Queue\Events\JobProcessed;
use Illuminate\Queue\Events\JobProcessing;
class AppServiceProvider extends ServiceProvider
{
public function boot()
{
Queue::before(function (JobProcessing $event) {
// $event->connectionName
// $event->job
// $event->job->payload()
});
Queue::after(function (JobProcessed $event) {
// $event->connectionName
// $event->job
// $event->job->payload()
});
}
}
Но нет никакой документации как реализовывать те самые события
Illuminate\Queue\Events\JobProcessed;
Illuminate\Queue\Events\JobProcessing;
Например я вызываю
MyJob::dispatch($data)->onQueue('myqueue');
Собственно вопрос:
Как мне оследить, что задача
- поставлена в очередь
- в процессе выполнения
- завершена
- провалена
???
ну писать куда нибудь что нибудь при after и before
Обсуждают сегодня