You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2022/04/19 12:02:57 UTC
[rocketmq] branch 5.0.0-beta updated: Minor polish
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch 5.0.0-beta
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/5.0.0-beta by this push:
new cc613d472 Minor polish
cc613d472 is described below
commit cc613d472d1e1f83baf0f59c936324e7cc7d089c
Author: Li Zhanhui <li...@gmail.com>
AuthorDate: Tue Apr 19 20:02:34 2022 +0800
Minor polish
---
.../org/apache/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 5d249f109..2042b96e4 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 <code>message</code> and return
* <code>ConsumeResult</code> 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 <code>message</code>, 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 <code>message</code> is properly processed; {@link ConsumeResult#FAILURE}
+ * otherwise.
*/
ConsumeResult consume(MessageView message);
}