|
...
|
...
|
@@ -45,11 +45,10 @@ public interface YhMessageConsumer { |
|
|
|
4. 初始化设置listenerContainer
|
|
|
|
5. 设置消费者，通过适配器适配(MessageListenerAdapter会适配YhMessageConsumer的handleMessage方法)。
|
|
|
|
这里也可以让YhMessageConsumer实现MessageListener接口作为消息处理监听者。
|
|
|
|
6. 创建队列
|
|
|
|
|
|
|
|
```1. 创建queue name：yoho:模块名:getMessageTopic
|
|
|
|
```2. 绑定queue<----->amq.topic<------>getMessageTopic
|
|
|
|
```3. 返回队列名new_queue
|
|
|
|
6. 创建队列
|
|
|
|
6.1. 创建queue name：yoho:模块名:getMessageTopic
|
|
|
|
6.2. 绑定queue<----->amq.topic<------>getMessageTopic
|
|
|
|
6.3. 返回队列名new_queue
|
|
|
|
7. listenerContainer设置监听队列名new_queue
|
|
|
|
8. 启动listenerContainer
|
|
|
|
|
...
|
...
|
|
