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 6ef2f43e fix(doc): correct incorrect statements in Design and Workflow
sections (#584)
6ef2f43e is described below
commit 6ef2f43e1baec94f8af05c6ea49322edb4cc4c29
Author: Gezi-lzq <[email protected]>
AuthorDate: Mon Aug 7 19:59:20 2023 +0800
fix(doc): correct incorrect statements in Design and Workflow sections
(#584)
---
docs/design.md | 2 +-
docs/workflow.md | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/design.md b/docs/design.md
index ea67e6ab..020917e8 100644
--- a/docs/design.md
+++ b/docs/design.md
@@ -55,7 +55,7 @@ Client identifier provides identity information for each
client event within the
* `macbook-pro`: hostname of device;
* `90009`: process identifier;
-* `2`: client index within current process;
+* `0`: client index within current process;
* `2dyeb8lep`: the unique string within process.
>**Note**: Implementations of client identifier by different languages may
>vary slightly, but the uniqueness is the first principle that must be
>followed.
diff --git a/docs/workflow.md b/docs/workflow.md
index 5fb6b5a8..4f4eb744 100644
--- a/docs/workflow.md
+++ b/docs/workflow.md
@@ -75,7 +75,7 @@ The receiving procedure is as follows:
1. Fetch the latest queue assignment from server.
2. If flow control occurs during message receiving, consumer will retry after
20 milliseconds, otherwise go to step3.
3. Cache message and trigger the consumption(Once the lifecycle of message is
over, it will removed from cache immediately).
-4. Check the cache is full, consumer will try to receive message immediately,
otherwise retry after 1 seconds.
+4. Check if the cache is full. If the cache is full, the consumer will attempt
to receive the message after 1 second; otherwise, it will retry immediately.
### Message Consumption in Push Consumer(Non-FIFO)
