tigroid3
@tigroid3
PHP, YII2, SQL, Postgres, Docker, SPHINX, GIT

Как удалить из очереди RabbitMQ при ошибке в Yii2?

Использую компонент queue.
'components' => [
    'queue' => [
            'class' => 'yii\queue\amqp_interop\Queue',
            'host' => 'localhost',
            'user' => 'guest',
            'password' => 'guest',
            'queueName' => 'queue_log_user',
    ],
]

добавляю в очередь так
Yii::$app->queue->push(new UserLogJob(['data' => [
            'ip' => $this->ip,
            'user_agent' => $this->userAgent,
            'created_at' => time(),
]]));

При любой ошибке очередь зависает и вся тормозится, как мне удалить позицию из очереди при любом эксепшене?
  • Вопрос задан
  • 437 просмотров
Пригласить эксперта
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы