You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by di...@apache.org on 2020/05/08 06:38:16 UTC

[rocketmq-client-python] branch master updated: [ISSUE #88]Sample Callback should return ConsumeStatus (#90)

This is an automated email from the ASF dual-hosted git repository.

dinglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-python.git


The following commit(s) were added to refs/heads/master by this push:
     new 7e9ffd9  [ISSUE #88]Sample Callback should return ConsumeStatus (#90)
7e9ffd9 is described below

commit 7e9ffd91c3f94a9e2ab3971ced6fb329a0c7e6ec
Author: Lin <ys...@gmail.com>
AuthorDate: Fri May 8 14:38:11 2020 +0800

    [ISSUE #88]Sample Callback should return ConsumeStatus (#90)
---
 README.md | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/README.md b/README.md
index f59d545..2140022 100644
--- a/README.md
+++ b/README.md
@@ -74,11 +74,12 @@ producer.shutdown()
 ```python
 import time
 
-from rocketmq.client import PushConsumer
+from rocketmq.client import PushConsumer, ConsumeStatus
 
 
 def callback(msg):
     print(msg.id, msg.body)
+    return ConsumeStatus.CONSUME_SUCCESS
 
 
 consumer = PushConsumer('CID_XXX')