Регистрация транспортов

ВАЖНО

Начиная с версии 5.1 пакета symfony/messenger транспорты AMQP, Redis и Doctrine вынесены в отдельные пакеты и в будущем будут удалены из основного пакета.

Регистрация транспорта на примере Redis

Composer

composer require symfony/redis-messenger

Регистрация фабрики

<?php
// local/php_interface/init.php
use Bitrix\Main\Loader;
use Bsi\Queue\Queue;
use Symfony\Component\Messenger\Bridge\Redis\Transport\RedisTransportFactory;

if (Loader::includeModule('bsi.queue')) {
    $queue = Queue::getInstance();
    $queue->registerTransportFactory('redis', RedisTransportFactory::class);
    $queue->boot();
}

Пример конфигурации

[
    // ...
    'transports' => [
       'async' => [
           'dsn' => 'redis://redis:6379/messages',
       ],
    ],
    // ...
];

ВАЖНО

Обработчики должны добавляться до инициализации системы очередей (вызова метода boot()).

Ссылки по теме:

• Messenger: Sync & Queued Message Handling (opens new window)