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

lizhanhui pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new a7b2cc367 Use StandardCharsets.UTF_8 as default charset of getting 
bytes when sending example messages (#5140)
a7b2cc367 is described below

commit a7b2cc3675ce05578f2bdcd350a6f66a51482af0
Author: renyansongno1 <[email protected]>
AuthorDate: Tue Sep 20 23:08:21 2022 +0800

    Use StandardCharsets.UTF_8 as default charset of getting bytes when sending 
example messages (#5140)
---
 .../src/main/java/org/apache/rocketmq/example/simple/Producer.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/example/src/main/java/org/apache/rocketmq/example/simple/Producer.java 
b/example/src/main/java/org/apache/rocketmq/example/simple/Producer.java
index 2b838a2eb..920d481b9 100644
--- a/example/src/main/java/org/apache/rocketmq/example/simple/Producer.java
+++ b/example/src/main/java/org/apache/rocketmq/example/simple/Producer.java
@@ -20,7 +20,7 @@ import org.apache.rocketmq.client.exception.MQClientException;
 import org.apache.rocketmq.client.producer.DefaultMQProducer;
 import org.apache.rocketmq.client.producer.SendResult;
 import org.apache.rocketmq.common.message.Message;
-import org.apache.rocketmq.remoting.common.RemotingHelper;
+import java.nio.charset.StandardCharsets;
 
 public class Producer {
 
@@ -37,14 +37,15 @@ public class Producer {
         //producer.setNamesrvAddr(DEFAULT_NAMESRVADDR);
 
         producer.start();
-        for (int i = 0; i < 128; i++)
+        for (int i = 0; i < 128; i++) {
             try {
-                Message msg = new Message(TOPIC, TAG, "OrderID188", "Hello 
world".getBytes(RemotingHelper.DEFAULT_CHARSET));
+                Message msg = new Message(TOPIC, TAG, "OrderID188", "Hello 
world".getBytes(StandardCharsets.UTF_8));
                 SendResult sendResult = producer.send(msg);
                 System.out.printf("%s%n", sendResult);
             } catch (Exception e) {
                 e.printStackTrace();
             }
+        }
 
         producer.shutdown();
     }

Reply via email to