Всем привет! Кто знаком с 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)),
]);
});
