commit 2c1969d0b2a7fcec814c36c2a8d9cbb81f6d060b
author Li Zhanhui <lizhanhui@gmail.com> Wed Sep 22 16:42:35 2021 +0800
committer Li Zhanhui <lizhanhui@gmail.com> Wed Sep 22 16:42:35 2021 +0800
tree 99af85136de1220bf5bb407f9fd9c8d566643e96
parent c7a6cddc62a8573b0e240ba2f6071de25fed70a2

Fix unit tests

src/test/cpp/ut/rocketmq/DefaultMQProducerTest.cpp

diff --git a/src/test/cpp/ut/rocketmq/DefaultMQProducerTest.cpp b/src/test/cpp/ut/rocketmq/DefaultMQProducerTest.cpp
index e827a1e..3d8b3d3 100644
--- a/src/test/cpp/ut/rocketmq/DefaultMQProducerTest.cpp
+++ b/src/test/cpp/ut/rocketmq/DefaultMQProducerTest.cpp
@@ -66,6 +66,7 @@
   std::string access_key_{"access_key"};
   std::string access_secret_{"access_secret"};
   std::shared_ptr<CredentialsProvider> credentials_provider_;
+  std::string body_{"Test message body"};
 };
 
 TEST_F(DefaultMQProducerUnitTest, testBasicSetUp) {
@@ -135,8 +136,10 @@
   producer->withNameServerResolver(name_server_resolver_);
   producer->setCredentialsProvider(credentials_provider_);
   producer->start();
+  
   MQMessage message;
   message.setTopic(topic_);
+  message.setBody(body_);
 
   absl::Mutex mtx;
   absl::CondVar cv;
@@ -158,7 +161,11 @@
   producer->withNameServerResolver(name_server_resolver_);
   producer->setCredentialsProvider(credentials_provider_);
   producer->start();
+
   MQMessage message;
+  message.setTopic(topic_);
+  message.setBody(body_);
+
   SendResult send_result = producer->send(message);
   ASSERT_EQ(send_result.getMsgId(), message_id_);
   producer->shutdown();