|
...
|
...
|
@@ -73,10 +73,10 @@ TTl队列内的消息在到达ttl时间时就过期成为一个deadMsg。利用D |
|
|
|
**x-dead-letter-routing-key** : 超时消息被丢弃时使用的routing-key
|
|
|
|
|
|
|
|
|
|
|
|
然后我们需要创建一个队列(final_queue)专门来接收这些deadMsg，队列需要绑定到x-dead-letter-exchange，如果有x-dead-letter-routing-key的话通过其绑定，如果未设置x-dead-letter-routing-key，则通过原来的routing-key进行绑定。<br>
|
|
|
|
然后我们需要创建一个队列(final_queue)专门来接收这些deadMsg，队列需要绑定到x-dead-letter-exchange，如果有x-dead-letter-routing-key的话通过其订阅消息，如果未设置x-dead-letter-routing-key，则通过原来的routing-key进行订阅消息。<br>
|
|
|
|
|
|
|
|
|
|
|
|
最后延时消息的消费者通过绑定final_queue队列，达成消息的延时处理。
|
|
|
|
最后延时消息的消费者通过订阅处理final_queue队列，实现消息的延时处理。
|
|
|
|
|
|
|
|
|
|
|
|
## DelayConsumerFactory初始化过程
|
...
|
...
|
|
