通过 Symfony Messenger 发送 x-message-ttl 到 RabbitMQ

Question

如何使用 Symfony Messenger 为 RabbitMQ 队列定义 x-message-ttl？

我看到它与 DelayStamp 一起使用，但我不想设置延迟。如果在特定时间范围内未处理消息，我只想丢弃消息。我没有在源代码的其他任何地方看到它被引用。

我能找到的唯一文档是有关使用 OldSound RabbitMq 包的旧方法的文档。

Answer 1

我是通过this PR间接弄明白的。

messenger.yaml

framework:
    messenger:
        transports:
            mywork:
                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
                options:
                    exchange:
                        name: mywork
                        type: direct
                    queues:
                        mywork:
                            arguments:
                                x-message-ttl: 60000

通过 Symfony Messenger 发送 x-message-ttl 到 RabbitMQ

Sending x-message-ttl to RabbitMQ through Symfony Messenger

symfony

rabbitmq