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

jinrongtong pushed a commit to branch new-official-website
in repository https://gitbox.apache.org/repos/asf/rocketmq-site.git


The following commit(s) were added to refs/heads/new-official-website by this 
push:
     new fe4320346 [ISSUE #400]update 06consumertype.md SimpleConsumer code
fe4320346 is described below

commit fe4320346ebb315d66c9fdb9d0c18cccb7cb6d5c
Author: WesleyOne <[email protected]>
AuthorDate: Tue Jan 31 10:29:35 2023 +0800

    [ISSUE #400]update 06consumertype.md SimpleConsumer code
---
 .../version-5.0/04-featureBehavior/06consumertype.md                    | 2 ++
 versioned_docs/version-5.0/04-featureBehavior/06consumertype.md         | 2 ++
 2 files changed, 4 insertions(+)

diff --git 
a/i18n/en/docusaurus-plugin-content-docs/version-5.0/04-featureBehavior/06consumertype.md
 
b/i18n/en/docusaurus-plugin-content-docs/version-5.0/04-featureBehavior/06consumertype.md
index 4edd24308..424826226 100644
--- 
a/i18n/en/docusaurus-plugin-content-docs/version-5.0/04-featureBehavior/06consumertype.md
+++ 
b/i18n/en/docusaurus-plugin-content-docs/version-5.0/04-featureBehavior/06consumertype.md
@@ -144,6 +144,8 @@ SimpleConsumer involves multiple API operations. The 
corresponding operations ar
                 
.setClientConfiguration(ClientConfiguration.newBuilder().setEndpoints("Your 
Endpoint").build())
                 // Specify the pre-bound subscriptions. 
                 .setSubscriptionExpressions(Collections.singletonMap(topic, 
filterExpression))
+                // Specify the max await time when receive messages from the 
server.
+                .setAwaitDuration(Duration.ofSeconds(1))
                 .build();
         List<MessageView> messageViewList = null;
         try {
diff --git a/versioned_docs/version-5.0/04-featureBehavior/06consumertype.md 
b/versioned_docs/version-5.0/04-featureBehavior/06consumertype.md
index b3a706a4b..e54304e0a 100644
--- a/versioned_docs/version-5.0/04-featureBehavior/06consumertype.md
+++ b/versioned_docs/version-5.0/04-featureBehavior/06consumertype.md
@@ -149,6 +149,8 @@ SimpleConsumer 的使用涉及多个接口调用,由业务逻辑按需调用
                 
.setClientConfiguration(ClientConfiguration.newBuilder().setEndpoints("Your 
Endpoint").build())
                 //设置预绑定的订阅关系。
                 .setSubscriptionExpressions(Collections.singletonMap(topic, 
filterExpression))
+                //设置从服务端接受消息的最大等待时间
+                .setAwaitDuration(Duration.ofSeconds(1))
                 .build();
         List<MessageView> messageViewList = null;
         try {

Reply via email to