You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2023/01/31 02:29:39 UTC
[rocketmq-site] branch new-official-website updated: [ISSUE #400]update 06consumertype.md SimpleConsumer code
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 <we...@163.com>
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 {