Мне нужно иметь две отдельные шины сообщений, чтобы использовать их с разными (несовместимыми) наборами промежуточного программного обеспечения.
Мне нужны наборы сообщений, промежуточного программного обеспечения и класса обработчика:
CommandMessage -> CommandMessageMiddlware -> CommandMessageHandler
EventMessage -> EventMessageMiddlware -> EventMessageHandler
Я делаю config/packages/messenger.yaml
framework:
messenger:
default_bus: command.bus
buses:
event.bus:
middleware:
- App\Middleware\EventMessageMiddlware
command.bus:
middleware:
- App\Middleware\CommandMessageMiddlware
И добавьте в config/services.yaml
services
...
...
App\Message\:
resource: '../src/Message'
autoconfigure: false
App\MessageHandler\:
resource: '../src/MessageHandler'
autoconfigure: false
App\MessageHandler\Event\EventMessageHandler:
autoconfigure: false
tags:
- name: messenger.message_handler
bus: event.bus
handles: App\Message\Event\EventMessage
App\MessageHandler\Command\CommandMessageHandler:
autoconfigure: false
tags:
- name: messenger.message_handler
bus: command.bus
handles: App\Message\Command\CommandMessage
Результат:
// works as expected with CommandMessageMiddlware
// on default "command.bus"
$this->bus->dispatch(new CommandMessage());
// BUT! There I have 'No handler for message "App\Message\Event\EventMessage"'
$this->bus->dispatch(new EventMessage());
Каждый раз, когда я отправляю какое-либо событие на шину сообщений, отличную от умолчанию, у меня возникает ошибка «Нет обработчика для сообщения XXX»
Это команда messager:debug:
Messenger
=========
command.bus
-----------
The following messages can be dispatched:
------------------------------------------------------------------------------------------------------
Messages for COMMAND bus
App\Message\Command\CommandMessage
handled by App\MessageHandler\Command\CommandMessageHandler (when bus=command.bus)
------------------------------------------------------------------------------------------------------
event.bus
---------
The following messages can be dispatched:
----------------------------------------------------------------------------------------------------
Messages for EVENT bus
App\Message\Event\EventMessage
handled by App\MessageHandler\Event\EventMessageHandler (when bus=event.bus)
----------------------------------------------------------------------------------------------------
Подробнее здесь: https://stackoverflow.com/questions/790 ... ed-message
