pro-dev
@pro-dev

Как подключить Symfony Messenger?

Всем привет! Кто знаком с Messenger от Symfony - можете подсказать как настроить транспорт для RabbitMQ? Единственный нюанс - хочу использовать его не в симфонии. Поэтому и спрашиваю. Сейчас настроил только синхронные запросы:

$configApp['params']['message_bus'] = [
    'handlers' => [
        Message::class => [Handler::class],
    ],
];
MessageBusInterface::class => function (Container $container) use ($configApp) {
    $config = $configApp['params']['message_bus'];
    $handlers = [];
    foreach ($config['handlers'] as $message => $handlers) {
        foreach ($handlers as $handler)  {
            $handlers[$message][] = $container->get($handler);
        }
    }
    return new MessageBus([
        new HandleMessageMiddleware(new HandlersLocator($handlers)),
    ]);
});
  • Вопрос задан
  • 179 просмотров
Пригласить эксперта
Ваш ответ на вопрос

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

Похожие вопросы