yii2 - 如何使用 Yii2 Queue::EVENT_AFTER_ERROR 事件

Question

我正在使用 Yii2 队列扩展。

我想在作业中触发错误事件后添加错误处理程序。

这是我的模型:

namespace app\models;

use Yii;
use yii\base\BaseObject;
use yii\queue\JobInterface;
use yii\queue\Queue;

class AddTransaction extends BaseObject implements JobInterface
{
    public function execute($queue)
    {
        $test = new League();
        $test->title_fa = 'تست';
        $test->title_en = 'test';
        $test->status = 1;
        $test->country_id = 3;
        $test->created = time();
        $test->save();
    }
}

这是我的行动:

public function actionTest()
{
    if (Yii::$app->queue->delay(5)->push(new AddTransaction())) {
        echo "ok";
    } else {
        echo "error";
    }
}

在哪里使用此代码？

Yii::$app->queue->on(Queue::EVENT_AFTER_ERROR, function (ErrorEvent $event) {
     if ($event->job instanceof SomeJob) {
         $event->retry = ($event->attempt < 5) && ($event->error instanceof TemporaryException);
     }
});

Answer 1

您可以将其添加到队列配置数组中:

'components' => [
    // ...
    'queue' => [
        // ...
        'on afterError' => function (ExecEvent $event) {
            if ($event->job instanceof SomeJob) {
                $event->retry = ($event->attempt < 5) && ($event->error instanceof TemporaryException);
            }
        },
    ],
],