Commit 403d17a30de3a4527b11f124c6f0ccf1b97ddab0
1 parent
14a1b362
添加注释
Showing
1 changed file
with
5 additions
and
0 deletions
src/main/java/org/apache/rocketmq/spring/starter/core/RocketMQListener.java
@@ -18,5 +18,10 @@ | @@ -18,5 +18,10 @@ | ||
18 | package org.apache.rocketmq.spring.starter.core; | 18 | package org.apache.rocketmq.spring.starter.core; |
19 | 19 | ||
20 | public interface RocketMQListener<T> { | 20 | public interface RocketMQListener<T> { |
21 | + /** | ||
22 | + * 消费消息接口,由应用来实现<br/> | ||
23 | + * 网络抖动等不稳定的情形可能会带来消息重复,对重复消息敏感的业务可对消息做幂等处理<br/> | ||
24 | + * 没有异常则表示处理成功,否在处理失败,处理失败时阿里云MQ会重复调用,最多调用16次,如果16次依然失败,则不再调用。 | ||
25 | + */ | ||
21 | void onMessage(T message); | 26 | void onMessage(T message); |
22 | } | 27 | } |