Попытка отправить уведомление pu sh с помощью задания
Рабочий не выдает ошибку тайм-аута, когда я запускаю php artisan queue:work
с Supervisor
и продолжаю обрабатывать элемент одиночной очереди несколько раз
Когда я попробовал php artisan queue:listen
, он выдал мне ошибку, что он получил тайм-аут через 60 секунд.
The process "'/usr/bin/php7.2' 'artisan' queue:work '' --once --queue='default' --delay=0 --memory=128 --sleep=3 --tries=0" exceeded the timeout of 60 seconds.
Я могу заставить обработчик обрабатывать все в течение 60 секунд на данный момент, но я хочу это исправить.
Что мне не хватает?
Работа умирает, не завершается и не завершается
Я использую Laravel 5.5
Команда, которую я запускаю с супервизором: php artisan queue:work
Пробовал запускать php artisan queue:restart
и перезапускал также и супервизор!
Журнал работника супервизора
[2020-08-07 13:26:35] Processing: App\Jobs\SendNotifications
[2020-08-07 13:28:05] Processing: App\Jobs\SendNotifications
[2020-08-07 13:29:36] Processing: App\Jobs\SendNotifications
[2020-08-07 13:31:07] Processing: App\Jobs\SendNotifications
[2020-08-07 13:32:38] Processing: App\Jobs\SendNotifications
[2020-08-07 13:34:08] Processing: App\Jobs\SendNotifications
[2020-08-07 13:35:39] Processing: App\Jobs\SendNotifications
Отправить уведомления. php
<?php
namespace App\Jobs;
use Exception;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Redis;
class SendNotifications implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
public $payload;
/**
* The number of times the job may be attempted.
*
* @var int
*/
public $tries = 3;
/**
* The number of seconds the job can run before timing out.
*
* @var int
*/
public $timeout = 60;
/**
* Create a new job instance.
*
* @return void
*/
public function __construct($payload)
{
$this->payload = $payload;
}
/**
* Execute the job.
*
* @return void
*/
public function handle()
{
try {
$this->handleNotifications($this->payload);
} catch (Exception $e) {
$this->failed($e);
}
}
/**
* The job failed to process.
*
* @param Exception $exception
* @return void
*/
public function failed(Exception $exception)
{
app('log')->error($exception->getMessage());
}
/**
* Method to compose the mail template
*
* @param json $payloadData
* @return void
*/
public function handleNotifications($payload)
{
..........
}
}