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 d34ec4f47 [ISSUE #578] fixed modify the example code
d34ec4f47 is described below
commit d34ec4f4721b05bedb3535ef695db3a8640887b0
Author: chuxiwen <[email protected]>
AuthorDate: Mon Jul 24 08:51:29 2023 +0800
[ISSUE #578] fixed modify the example code
Signed-off-by: chuxiwen <[email protected]>
---
versioned_docs/version-5.0/04-featureBehavior/01normalmessage.md | 2 +-
versioned_docs/version-5.0/04-featureBehavior/02delaymessage.md | 2 +-
versioned_docs/version-5.0/04-featureBehavior/03fifomessage.md | 2 +-
versioned_docs/version-5.0/04-featureBehavior/04transactionmessage.md | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/versioned_docs/version-5.0/04-featureBehavior/01normalmessage.md
b/versioned_docs/version-5.0/04-featureBehavior/01normalmessage.md
index ff51b8380..dfae7ffd1 100644
--- a/versioned_docs/version-5.0/04-featureBehavior/01normalmessage.md
+++ b/versioned_docs/version-5.0/04-featureBehavior/01normalmessage.md
@@ -54,7 +54,7 @@ sh mqadmin updateTopic -n <nameserver_address> -t
<topic_name> -c <cluster_name>
```java
//普通消息发送。
-MessageBuilder messageBuilder = new MessageBuilder();
+MessageBuilder messageBuilder = new MessageBuilderImpl();
Message message = messageBuilder.setTopic("topic")
//设置消息索引键，可根据关键字精确查找某条消息。
.setKeys("messageKey")
diff --git a/versioned_docs/version-5.0/04-featureBehavior/02delaymessage.md
b/versioned_docs/version-5.0/04-featureBehavior/02delaymessage.md
index 7035962f5..4b4af7be2 100644
--- a/versioned_docs/version-5.0/04-featureBehavior/02delaymessage.md
+++ b/versioned_docs/version-5.0/04-featureBehavior/02delaymessage.md
@@ -112,7 +112,7 @@ sh mqadmin updateTopic -n <nameserver_address> -t
<topic_name> -c <cluster_name>
```java
//定时/延时消息发送
- MessageBuilder messageBuilder = null;
+ MessageBuilder messageBuilder = new MessageBuilderImpl();;
//以下示例表示：延迟时间为10分钟之后的Unix时间戳。
Long deliverTimeStamp = System.currentTimeMillis() + 10L * 60 * 1000;
Message message = messageBuilder.setTopic("topic")
diff --git a/versioned_docs/version-5.0/04-featureBehavior/03fifomessage.md
b/versioned_docs/version-5.0/04-featureBehavior/03fifomessage.md
index d8f332047..445ebaa9d 100644
--- a/versioned_docs/version-5.0/04-featureBehavior/03fifomessage.md
+++ b/versioned_docs/version-5.0/04-featureBehavior/03fifomessage.md
@@ -152,7 +152,7 @@ sh mqadmin updateTopic -n <nameserver_address> -t
<topic_name> -c <cluster_name>
```java
//顺序消息发送。
- MessageBuilder messageBuilder = null;
+ MessageBuilder messageBuilder = new MessageBuilderImpl();;
Message message = messageBuilder.setTopic("topic")
//设置消息索引键，可根据关键字精确查找某条消息。
.setKeys("messageKey")
diff --git
a/versioned_docs/version-5.0/04-featureBehavior/04transactionmessage.md
b/versioned_docs/version-5.0/04-featureBehavior/04transactionmessage.md
index a2486e5da..4db185f69 100644
--- a/versioned_docs/version-5.0/04-featureBehavior/04transactionmessage.md
+++ b/versioned_docs/version-5.0/04-featureBehavior/04transactionmessage.md
@@ -156,7 +156,7 @@ sh mqadmin updateTopic -n <nameserver_address> -t
<topic_name> -c <cluster_name>
}
public static void main(String[] args) throws ClientException {
ClientServiceProvider provider = new ClientServiceProvider();
- MessageBuilder messageBuilder = new MessageBuilder();
+ MessageBuilder messageBuilder = new MessageBuilderImpl();
//构造事务生产者：事务消息需要生产者构建一个事务检查器，用于检查确认异常半事务的中间状态。
Producer producer = provider.newProducerBuilder()
.setTransactionChecker(messageView -> {
