[incubator-tubemq] 36/49: [TUBEMQ-510] Found a bug in MessageProducerExample class

[yuanbo]

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

yuanbo pushed a commit to branch TUBEMQ-421
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git

commit a7ae74e164b551baca51ef5104d2a9653a694fe4
Author: gosonzhang <gosonzh...@tencent.com>
AuthorDate: Tue Jan 12 14:55:23 2021 +0800

    [TUBEMQ-510] Found a bug in MessageProducerExample class
---
 .../src/main/java/org/apache/tubemq/example/MessageProducerExample.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/tubemq-example/src/main/java/org/apache/tubemq/example/MessageProducerExample.java
 
b/tubemq-example/src/main/java/org/apache/tubemq/example/MessageProducerExample.java
index 2b806b5..0bac5ef 100644
--- 
a/tubemq-example/src/main/java/org/apache/tubemq/example/MessageProducerExample.java
+++ 
b/tubemq-example/src/main/java/org/apache/tubemq/example/MessageProducerExample.java
@@ -104,7 +104,7 @@ public final class MessageProducerExample {
             while (msgCount < 0 || sentCount < msgCount) {
                 roundIndex = (int) (sentCount++ % targetCnt);
                 Tuple2<String, String> target = 
topicSendRounds.get(roundIndex);
-                Message message = new Message(target.getF0(), body.getBytes());
+                Message message = new Message(target.getF0(), 
dataBuffer.array());
                 long currTimeMillis = System.currentTimeMillis();
                 message.setAttrKeyVal("index", String.valueOf(sentCount));
                 message.setAttrKeyVal("dataTime", 
String.valueOf(currTimeMillis));