2016-12-22 53 views
0

使用Spring AMQP(使用RabbitMQ作为消息代理),我正在准备一条消息,并且我希望消息有时会消耗。等到等待队列,然后移动到我们的主队列,在那里我们有消费者正在等待处理消息从主队列RabbitMQ Spring AMQP - 一段时间后的消息处理

我很困惑我是否应该在这种情况下应用死信交换以及如何申请死信交换是我的大问题。

任何想法我们如何才能使其工作。

P.S>如果没有rabbitmq_delayed_message_exchange插件是可能的。

回答

1

如果您不想使用延迟交换插件,则可以将消息发送到具有生存时间的队列(ttl设置在队列或消息中)。

配置队列将过期的消息路由到一个死信交换,该交换路由到最终队列。

someExchange -> ttlQueueWithDLX -> DLX -> liveQueue 
相关问题