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 {