...
|
...
|
@@ -14,6 +14,8 @@ send(String topic, Object object, Map<String, Object> attributes) |
|
|
```java
|
|
|
send(String topic, Object object, Map<String, Object> attributes,int delayInMinutes)
|
|
|
```
|
|
|
|
|
|
|
|
|
延时消息发送接口内部也是调用普通消息进行发送,不过其会根据延时时间发送到指定的延时队列中.
|
|
|
|
|
|
而对于消费者Consumer,不管是普通消息的消费者还是延时消息的消费者,yoho-core中需要完成两件事情。
|
...
|
...
|
@@ -44,9 +46,15 @@ public interface YhMessageConsumer { |
|
|
5. 设置消费者,通过适配器适配(MessageListenerAdapter会适配YhMessageConsumer的handleMessage方法)。
|
|
|
这里也可以让YhMessageConsumer实现MessageListener接口作为消息处理监听者。
|
|
|
6. 创建队列
|
|
|
6.1. 创建queue name:yoho:模块名:getMessageTopic
|
|
|
6.2. 绑定queue<----->amq.topic<------>getMessageTopic
|
|
|
6.3. 返回队列名new_queue
|
|
|
|
|
|
|
|
|
6.1. 创建queue name:yoho:模块名:getMessageTopic
|
|
|
|
|
|
|
|
|
6.2. 绑定queue<----->amq.topic<------>getMessageTopic
|
|
|
|
|
|
|
|
|
6.3. 返回队列名new_queue
|
|
|
7. listenerContainer设置监听队列名new_queue
|
|
|
8. 启动listenerContainer
|
|
|
|
...
|
...
|
|