diff --git a/src/main/java/org/apache/rocketmq/spring/starter/core/RocketMQListener.java b/src/main/java/org/apache/rocketmq/spring/starter/core/RocketMQListener.java index e56a7e8..64daa5f 100644 --- a/src/main/java/org/apache/rocketmq/spring/starter/core/RocketMQListener.java +++ b/src/main/java/org/apache/rocketmq/spring/starter/core/RocketMQListener.java @@ -18,5 +18,10 @@ package org.apache.rocketmq.spring.starter.core; public interface RocketMQListener { + /** + * 消费消息接口,由应用来实现
+ * 网络抖动等不稳定的情形可能会带来消息重复,对重复消息敏感的业务可对消息做幂等处理
+ * 没有异常则表示处理成功,否在处理失败,处理失败时阿里云MQ会重复调用,最多调用16次,如果16次依然失败,则不再调用。 + */ void onMessage(T message); }