[rocketmq-clients] 11/11: Fill as many fields as possible for Settings#Publishing

[li...@apache.org]

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

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

commit f3f25916b5277916ed5c4c975b6c842658de8afe
Author: Zhanhui Li <li...@apache.org>
AuthorDate: Fri Sep 23 15:18:11 2022 +0800

    Fill as many fields as possible for Settings#Publishing
---
 cpp/source/rocketmq/ProducerImpl.cpp | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/cpp/source/rocketmq/ProducerImpl.cpp b/cpp/source/rocketmq/ProducerImpl.cpp
index 7ad127c..2029d39 100644
--- a/cpp/source/rocketmq/ProducerImpl.cpp
+++ b/cpp/source/rocketmq/ProducerImpl.cpp
@@ -581,7 +581,11 @@ void ProducerImpl::topicsOfInterest(std::vector<std::string> topics) {
 void ProducerImpl::buildClientSettings(rmq::Settings& settings) {
   settings.set_client_type(rmq::ClientType::PRODUCER);
 
-  auto topics = settings.mutable_publishing()->mutable_topics();
+  auto publishing_setting = settings.mutable_publishing();
+  publishing_setting->set_validate_message_type(false);
+  publishing_setting->set_max_body_size(MixAll::MAX_MESSAGE_BODY_SIZE);
+  
+  auto topics = publishing_setting->mutable_topics();
   {
     absl::MutexLock lk(&topics_mtx_);
     for (const auto& item : topics_) {