|
...
|
...
|
@@ -83,17 +83,28 @@ TTl队列内的消息在到达ttl时间时就过期成为一个deadMsg。利用D |
|
|
|
5. 设置消费者，通过适配器适配(MessageListenerAdapter会适配YhMessageConsumer的handleMessage方法)。
|
|
|
|
这里也可以让YhMessageConsumer实现MessageListener接口作为消息处理监听者。
|
|
|
|
6. 创建延时队列<br>
|
|
|
|
-----6.1. 创建timeQueue ```
|
|
|
|
|
|
|
|
|
|
|
|
-----6.1. 创建timeQueue
|
|
|
|
```
|
|
|
|
**name**： delay:[delayInMinutes]m.queue
|
|
|
|
**x-message-ttl** : delayInMinutes
|
|
|
|
**x-dead-letter-exchange** : yoho.expire```
|
|
|
|
|
|
|
|
|
|
|
|
-----6.2. 绑定 <br>
|
|
|
|
delay:[delayInMinutes]m.queue<----->amq.topic<------>yoho_delay.[delayInMinutes]m.*
|
|
|
|
7. 创建最终消费队列<br>
|
|
|
|
-----7.1 创建expiredQueue <br>
|
|
|
|
|
|
|
|
|
|
|
|
-----7.1 创建expiredQueue <br>
|
|
|
|
name：yoho_delay:模块名:getMessageTopic<br>
|
|
|
|
|
|
|
|
|
|
|
|
-----7.2 绑定<br>
|
|
|
|
yoho_delay:模块名:getMessageTopic<----->yoho.expire<------>yoho_delay.*.getMessageTopic<br>
|
|
|
|
|
|
|
|
|
|
|
|
-----7.3 返回expiredQueue队列名<br>
|
|
|
|
8. listenerContainer设置监听队列名expiredQueue
|
|
|
|
9. 启动listenerContainer
|
...
|
...
|
|
