[rocketmq-clients] branch cpp_dev updated: Add error handling for MESSAGE_PROPERTY_CONFLICT_WITH_TYPE

[lizhanhui]

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

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


The following commit(s) were added to refs/heads/cpp_dev by this push:
     new 88e567a  Add error handling for MESSAGE_PROPERTY_CONFLICT_WITH_TYPE
88e567a is described below

commit 88e567a0166c1ef851c7207be492a67e5f84deb2
Author: Li Zhanhui <lizhan...@gmail.com>
AuthorDate: Tue Jul 26 17:20:54 2022 +0800

    Add error handling for MESSAGE_PROPERTY_CONFLICT_WITH_TYPE
---
 cpp/source/client/ClientManagerImpl.cpp | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/cpp/source/client/ClientManagerImpl.cpp 
b/cpp/source/client/ClientManagerImpl.cpp
index 115fbd4..b3a4559 100644
--- a/cpp/source/client/ClientManagerImpl.cpp
+++ b/cpp/source/client/ClientManagerImpl.cpp
@@ -438,6 +438,12 @@ bool ClientManagerImpl::send(const std::string& 
target_host, const Metadata& met
         break;
       }
 
+      case rmq::Code::MESSAGE_PROPERTY_CONFLICT_WITH_TYPE: {
+        SPDLOG_WARN("Message-property-conflict-with-type: Host={}, 
Response={}", invocation_context->remote_address, 
invocation_context->response.DebugString());
+        ec = ErrorCode::MessagePropertyConflictWithType;
+        break;
+      }
+
       default: {
         SPDLOG_WARN("NotSupported: Check and upgrade SDK to the latest. 
Host={}", invocation_context->remote_address);
         ec = ErrorCode::NotSupported;