Format the code style.
diff --git a/include/CProducer.h b/include/CProducer.h
index 7d533f9..a0968df 100644
--- a/include/CProducer.h
+++ b/include/CProducer.h
@@ -19,9 +19,9 @@
#define __C_PRODUCER_H__
#include "CBatchMessage.h"
+#include "CMQException.h"
#include "CMessage.h"
#include "CSendResult.h"
-#include "CMQException.h"
#ifdef __cplusplus
extern "C" {
@@ -79,7 +79,9 @@
CSendSuccessCallback cSendSuccessCallback,
CSendExceptionCallback cSendExceptionCallback);
ROCKETMQCLIENT_API int SendMessageOrderlyByShardingKey(CProducer* producer,
- CMessage* msg, const char * shardingKey, CSendResult* result);
+ CMessage* msg,
+ const char* shardingKey,
+ CSendResult* result);
#ifdef __cplusplus
};
diff --git a/src/extern/CProducer.cpp b/src/extern/CProducer.cpp
index 66acdc1..46216e6 100644
--- a/src/extern/CProducer.cpp
+++ b/src/extern/CProducer.cpp
@@ -17,8 +17,8 @@
#include "CProducer.h"
#include <string.h>
+#include <functional>
#include <typeindex>
-#include <string.h>
#include <typeinfo>
#include "AsyncCallback.h"
#include "CBatchMessage.h"
@@ -29,7 +29,6 @@
#include "DefaultMQProducer.h"
#include "MQClientErrorContainer.h"
#include "UtilAll.h"
-#include <functional>
#ifdef __cplusplus
extern "C" {
@@ -38,14 +37,14 @@
using namespace std;
class SelectMessageQueueInner : public MessageQueueSelector {
-public:
- MQMessageQueue select(const std::vector<MQMessageQueue>& mqs, const MQMessage& msg, void* arg) {
- int index = 0;
- std::string shardingKey = rocketmq::UtilAll::to_string((char *)arg);
+ public:
+ MQMessageQueue select(const std::vector<MQMessageQueue>& mqs, const MQMessage& msg, void* arg) {
+ int index = 0;
+ std::string shardingKey = rocketmq::UtilAll::to_string((char*)arg);
- index = std::hash<std::string>{}(shardingKey) % mqs.size();
- return mqs[index % mqs.size()];
- }
+ index = std::hash<std::string>{}(shardingKey) % mqs.size();
+ return mqs[index % mqs.size()];
+ }
};
class SelectMessageQueue : public MessageQueueSelector {
@@ -100,8 +99,8 @@
return (CProducer*)defaultMQProducer;
}
-CProducer* CreateOrderlyProducer(const char* groupId){
- return CreateProducer(groupId);
+CProducer* CreateOrderlyProducer(const char* groupId) {
+ return CreateProducer(groupId);
}
int DestroyProducer(CProducer* pProducer) {
if (pProducer == NULL) {
@@ -325,28 +324,27 @@
}
return OK;
}
-int SendMessageOrderlyByShardingKey(CProducer* producer,
- CMessage* msg, const char * shardingKey, CSendResult* result){
- if (producer == NULL || msg == NULL || shardingKey == NULL || result == NULL) {
- return NULL_POINTER;
- }
- DefaultMQProducer* defaultMQProducer = (DefaultMQProducer*)producer;
- MQMessage* message = (MQMessage*)msg;
- try {
- // Constructing SelectMessageQueue objects through function pointer callback
- int retryTimes = 3;
- SelectMessageQueueInner selectMessageQueue;
- SendResult sendResult = defaultMQProducer->send(*message, &selectMessageQueue, (void *)shardingKey, retryTimes);
- // Convert SendStatus to CSendStatus
- result->sendStatus = CSendStatus((int)sendResult.getSendStatus());
- result->offset = sendResult.getQueueOffset();
- strncpy(result->msgId, sendResult.getMsgId().c_str(), MAX_MESSAGE_ID_LENGTH - 1);
- result->msgId[MAX_MESSAGE_ID_LENGTH - 1] = 0;
- } catch (exception& e) {
- MQClientErrorContainer::setErr(string(e.what()));
- return PRODUCER_SEND_ORDERLY_FAILED;
- }
- return OK;
+int SendMessageOrderlyByShardingKey(CProducer* producer, CMessage* msg, const char* shardingKey, CSendResult* result) {
+ if (producer == NULL || msg == NULL || shardingKey == NULL || result == NULL) {
+ return NULL_POINTER;
+ }
+ DefaultMQProducer* defaultMQProducer = (DefaultMQProducer*)producer;
+ MQMessage* message = (MQMessage*)msg;
+ try {
+ // Constructing SelectMessageQueue objects through function pointer callback
+ int retryTimes = 3;
+ SelectMessageQueueInner selectMessageQueue;
+ SendResult sendResult = defaultMQProducer->send(*message, &selectMessageQueue, (void*)shardingKey, retryTimes);
+ // Convert SendStatus to CSendStatus
+ result->sendStatus = CSendStatus((int)sendResult.getSendStatus());
+ result->offset = sendResult.getQueueOffset();
+ strncpy(result->msgId, sendResult.getMsgId().c_str(), MAX_MESSAGE_ID_LENGTH - 1);
+ result->msgId[MAX_MESSAGE_ID_LENGTH - 1] = 0;
+ } catch (exception& e) {
+ MQClientErrorContainer::setErr(string(e.what()));
+ return PRODUCER_SEND_ORDERLY_FAILED;
+ }
+ return OK;
}
int SetProducerGroupName(CProducer* producer, const char* groupName) {
if (producer == NULL) {