小编Kev*_*res的帖子

使用 Messenger 读取未通过 Messenger 发送的排队消息

我正在尝试读取未通过 Symfony Messenger 发送的排队消息(在 RabbitMQ 中)。似乎 Messenger 添加了一些标题,例如

headers: 
    type: App\Message\Transaction
Run Code Online (Sandbox Code Playgroud)

但是在读取外部消息时,此标头不存在。

那么,有没有办法告诉 Messenger 队列 A 中的每条消息都必须被视为消息类型Transaction

我今天所拥有的是:

framework:
    messenger:
        transports:
            # Uncomment the following line to enable a transport named "amqp"
            amqp:
                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                options:
                    exchange:
                        name: messages
                        type: direct
                    queue:
                        name: queue_messages

        routing:
            # Route your messages to the transports
             'App\Message\Transaction': amqp
Run Code Online (Sandbox Code Playgroud)

我想补充的是:

        routing:
            # Route your messages to the transports
             amqp: 'App\Message\Transaction'
Run Code Online (Sandbox Code Playgroud)

rabbitmq symfony symfony-messenger

7
推荐指数
1
解决办法
1810
查看次数

标签 统计

rabbitmq ×1

symfony ×1

symfony-messenger ×1