framework:
messenger:
# Uncomment this (and the failed transport below) to send failed messages to this transport for later handling.
# failure_transport: failed
transports:
async: "%env(MESSENGER_TRANSPORT_DSN)%"
sync: 'sync://'
default_bus: messenger.bus.command
buses:
messenger.bus.command:
middleware:
- validation
messenger.bus.query:
middleware:
- validation
messenger.bus.event:
default_middleware: allow_no_handlers
routing:
'App\Core\Application\Command\AsyncCommand': async
'App\Core\Application\Command\SyncCommand': sync
'App\Core\Application\Query\SyncQuery': sync
|
