Add c interface to set client current language for Python SDK.

include/CProducer.h

@@ -103,6 +103,9 @@ ROCKETMQCLIENT_API int SendMessageTransaction(CProducer* producer,
                                               CLocalTransactionExecutorCallback callback,
                                               void* userData,
                                               CSendResult* result);
+
+ROCKETMQCLIENT_API int SetProducerLanguage(CProducer* producer,
+                                           const char* language);
 #ifdef __cplusplus
 }
 #endif

include/CPullConsumer.h

@@ -57,6 +57,8 @@ ROCKETMQCLIENT_API CPullResult
 Pull(CPullConsumer* consumer, const CMessageQueue* mq, const char* subExpression, long long offset, int maxNums);
 ROCKETMQCLIENT_API int ReleasePullResult(CPullResult pullResult);
 
+ROCKETMQCLIENT_API int SetPullConsumerLanguage(CPullConsumer* pullConsumer, const char* language);
+
 #ifdef __cplusplus
 }
 #endif

include/CPushConsumer.h

@@ -60,6 +60,7 @@ ROCKETMQCLIENT_API int SetPushConsumerMessageModel(CPushConsumer* consumer, CMes
 ROCKETMQCLIENT_API int SetPushConsumerMaxCacheMessageSize(CPushConsumer* consumer, int maxCacheSize);
 ROCKETMQCLIENT_API int SetPushConsumerMaxCacheMessageSizeInMb(CPushConsumer* consumer, int maxCacheSizeInMb);
 ROCKETMQCLIENT_API int SetPushConsumerMessageTrace(CPushConsumer* consumer, CTraceModel openTrace);
+ROCKETMQCLIENT_API int SetPushConsumerLanguage(CPushConsumer* consumer, const char* language);
 
 #ifdef __cplusplus
 }

src/common/MQVersion.cpp

@@ -31,5 +31,9 @@ const char* MQVersion::GetVersionDesc(int value) {
   }
   return RocketMQCPPClientVersion[currentVersion];
 }
+
+const void MQVersion::SetCurrentLanguage(const char* language) {
+  MQVersion::s_CurrentLanguage = language;
+}
 //<!***************************************************************************
 }  // namespace rocketmq

src/common/MQVersion.h

@@ -1526,6 +1526,7 @@ class MQVersion {
   };
 
   static const char* GetVersionDesc(int value);
+  static const void SetCurrentLanguage(const char* language);
   static int s_CurrentVersion;
   static std::string s_CurrentLanguage;
 };

src/extern/CProducer.cpp

@@ -33,6 +33,7 @@
 #include "TransactionMQProducer.h"
 #include "TransactionSendResult.h"
 #include "UtilAll.h"
+#include "MQVersion.h"
 
 #ifdef __cplusplus
 extern "C" {
@@ -815,6 +816,11 @@ int SetProducerMessageTrace(CProducer* producer, CTraceModel openTrace) {
   }
   return OK;
 }
+
+int SetProducerLanguage(CProducer* producer, const char* language) {
+  MQVersion::SetCurrentLanguage(language);
+  return OK;
+}
 #ifdef __cplusplus
 };
 #endif

src/extern/CPullConsumer.cpp

@@ -20,6 +20,7 @@
 #include "CMessageExt.h"
 #include "DefaultMQPullConsumer.h"
 #include "MQClientErrorContainer.h"
+#include "MQVersion.h"
 
 using namespace rocketmq;
 using namespace std;
@@ -254,6 +255,11 @@ int ReleasePullResult(CPullResult pullResult) {
   return OK;
 }
 
+int SetPullConsumerLanguage(CPullConsumer * consumer, const char* language) {
+  MQVersion::SetCurrentLanguage(language);
+  return OK;
+}
+
 #ifdef __cplusplus
 };
 #endif

src/extern/CPushConsumer.cpp

@@ -21,6 +21,7 @@
 #include "CMessageExt.h"
 #include "DefaultMQPushConsumer.h"
 #include "MQClientErrorContainer.h"
+#include "MQVersion.h"
 
 using namespace rocketmq;
 using namespace std;
@@ -304,6 +305,11 @@ int SetPushConsumerMessageTrace(CPushConsumer* consumer, CTraceModel openTrace)
   ((DefaultMQPushConsumer*)consumer)->setMessageTrace(messageTrace);
   return OK;
 }
+
+int SetPushConsumerLanguage(CPushConsumer * consumer, const char* language) {
+  MQVersion::SetCurrentLanguage(language);
+  return OK;
+}
 #ifdef __cplusplus
 };
 #endif

src/transport/ClientRemotingProcessor.cpp

@@ -19,6 +19,7 @@
 #include "ConsumerRunningInfo.h"
 #include "MQClientFactory.h"
 #include "UtilAll.h"
+#include "MQVersion.h"
 
 namespace rocketmq {
 
@@ -111,7 +112,7 @@ RemotingCommand* ClientRemotingProcessor::getConsumerRunningInfo(const string& a
   LOG_INFO("getConsumerRunningInfo:%s", requestHeader->getConsumerGroup().c_str());
 
   RemotingCommand* pResponse =
-      new RemotingCommand(request->getCode(), "CPP", request->getVersion(), request->getOpaque(), request->getFlag(),
+      new RemotingCommand(request->getCode(), MQVersion::s_CurrentLanguage, request->getVersion(), request->getOpaque(), request->getFlag(),
                           request->getRemark(), NULL);
 
   unique_ptr<ConsumerRunningInfo> runningInfo(