[rocketmq-clients] branch master updated: Add error handling for MESSAGE_PROPERTY_CONFLICT_WITH_TYPE (#73)

[li...@apache.org]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 99d423f  Add error handling for MESSAGE_PROPERTY_CONFLICT_WITH_TYPE (#73)
99d423f is described below

commit 99d423f9d3613d93c920ada3a132f64fa751f6f6
Author: Zhanhui Li <li...@gmail.com>
AuthorDate: Wed Jul 27 22:17:32 2022 +0800

    Add error handling for MESSAGE_PROPERTY_CONFLICT_WITH_TYPE (#73)
---
 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;