尽管在 Symfony Messenger 中将处理程序路由配置为异步，但消息未异步分派

Question

我正在使用 Symfony 4.4 和 Symfony Messenger

Messenger 配置包括传输和路由：

messenger:
    failure_transport: failed

    transports:
        async_medium:
            dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
            retry_strategy:
                max_retries: 3
                delay: 1000
        failed:
            ...

    routing:
        'Name\Space\MessageHandler\SnowplowNotificationHandler': async_medium

尽管处理程序看起来配置正确（当我运行控制台 debug:messenger 时，它显示正确分配给传输）

Messenger

messenger.bus.default

 The following messages can be dispatched:
  Name\Space\Message\SnowplowMessage                                                  
     handled by Name\Space\MessageHandler\SnowplowEmailNotificationHandler  

消息类SnowplowMessage不会排队，而是立即发送到_invoke()处理程序的方法。

我正在使用 AMQP（RabbitMQ 作为传输）并且它配置正确，因为没有显示错误并且命令控制台信使：setup-transport 正确创建队列

Answer 1

由于某种原因，这似乎是一个经常发生的错误，所以我宁愿发布答案而不是评论。

您应该将消息类添加到路由配置，而不是处理程序类。

如果您希望异步管理该消息，您的配置应该是：

routing:
        Name\Space\Message\SnowplowMessage: async_medium

您正在路由的是message。由于缺少上述配置，默认路由会同步处理消息。