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 <[email protected]> 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_) {
