From cc613d472d1e1f83baf0f59c936324e7cc7d089c Mon Sep 17 00:00:00 2001 From: Li Zhanhui Date: Tue, 19 Apr 2022 20:02:34 +0800 Subject: [PATCH] Minor polish --- .../rocketmq/apis/consumer/MessageListener.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/apis/src/main/java/org/apache/rocketmq/apis/consumer/MessageListener.java b/apis/src/main/java/org/apache/rocketmq/apis/consumer/MessageListener.java index 5d249f1092..2042b96e4d 100644 --- a/apis/src/main/java/org/apache/rocketmq/apis/consumer/MessageListener.java +++ b/apis/src/main/java/org/apache/rocketmq/apis/consumer/MessageListener.java @@ -38,13 +38,14 @@ public interface MessageListener { * business requirements through processing message and return * ConsumeResult accordingly. * - * Push consumer will, on behalf of its group, acknowledge the message to - * broker on SUCCESS; In case of FAILURE returned or unexpected exceptions + * PushConsumer will, on behalf of its group, acknowledge the message to + * broker on success; In case of failure or unexpected exceptions * were raised, it will negatively acknowledge message, which - * would potentially get re-delivered after configured back off period. + * would potentially get re-delivered after the configured back off period. * - * @param messageView is message which need consume. - * @return ConsumeResult which defined in {@link ConsumeResult} + * @param message Message to process. + * @return {@link ConsumeResult#SUCCESS} if message is properly processed; {@link ConsumeResult#FAILURE} + * otherwise. */ ConsumeResult consume(MessageView message); }