[ISSUE #578] fixed modify the example code

Signed-off-by: chuxiwen <[email protected]>
apache · Jul 24, 2023 · d34ec4f · d34ec4f
1 parent 5aaf3fc
commit d34ec4f
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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 -> {