opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

Minor polish

Browse Source
This commit is contained in:
Li Zhanhui
2022-04-19 20:02:34 +08:00
parent 46da67d73e
commit cc613d472d
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apis/src/main/java/org/apache/rocketmq/apis/consumer/MessageListener.java
+6 -5
View File
@@ -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);
}