This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new 20fd6fba [ISSUE #132] docs: correct images and add explanation for
Ack/ChangeInvisibleTime retry policy (#585)
20fd6fba is described below
commit 20fd6fba0969f59906cdd8706842ec695bf25804
Author: Gezi-lzq <[email protected]>
AuthorDate: Wed Aug 9 15:03:15 2023 +0800
[ISSUE #132] docs: correct images and add explanation for
Ack/ChangeInvisibleTime retry policy (#585)
* docs: correct images and add missing logic for Ack/ChangeInvisibleTime
retry policy
Signed-off-by: Gezi-lzq <[email protected]>
* docs: correct images
Signed-off-by: Gezi-lzq <[email protected]>
* docs: fix markdown style
Signed-off-by: Gezi-lzq <[email protected]>
* docs: fix doc style
Signed-off-by: Gezi-lzq <[email protected]>
---------
Signed-off-by: Gezi-lzq <[email protected]>
---
...ssage_consumption_in_push_consumer_non_FIFO.png | Bin 388151 -> 315673 bytes
docs/workflow.md | 4 ++++
2 files changed, 4 insertions(+)
diff --git a/docs/artwork/message_consumption_in_push_consumer_non_FIFO.png
b/docs/artwork/message_consumption_in_push_consumer_non_FIFO.png
index 8aa1e6f7..d01249bb 100644
Binary files a/docs/artwork/message_consumption_in_push_consumer_non_FIFO.png
and b/docs/artwork/message_consumption_in_push_consumer_non_FIFO.png differ
diff --git a/docs/workflow.md b/docs/workflow.md
index 4f4eb744..23cef13f 100644
--- a/docs/workflow.md
+++ b/docs/workflow.md
@@ -83,6 +83,10 @@ The receiving procedure is as follows:
<img src="./artwork/message_consumption_in_push_consumer_non_FIFO.png"
width="50%">
</div>
+In push consumer, we provide retry policies for acknowledging messages and
changing the invisible time to ensure the reliability of message processing.
+
+When calling `ackMessage` or `changeInvisibleDuration` methods, if receiving a
non-OK response code, we will log the error and retry later. We will retry the
method with an increasing attempt value until it succeeds. If receiving an
`INVALID_RECEIPT_HANDLE` response code, we will not retry and directly return
the exception to the caller.
+
### Message Consumption in Push Consumer(FIFO)
<div align="center">
