commit f2cba383447212ed2209960bb0c2717c52a3f695
author duhenglucky <duheng0522@gmail.com> Fri Oct 11 14:07:00 2019 +0800
committer duhenglucky <duheng0522@gmail.com> Fri Oct 11 14:07:00 2019 +0800
tree c553f1a279e34c16e67b6681a0ababf0adf4ffb7
parent 4805d35a174ba7555929f38eb857f6ca463f3122

fix(producer) fix declare CBatchMessage predefine error

src/PythonWrapper.cpp

diff --git a/src/PythonWrapper.cpp b/src/PythonWrapper.cpp
index 56dc58a..8efc1ba 100644
--- a/src/PythonWrapper.cpp
+++ b/src/PythonWrapper.cpp
@@ -17,6 +17,7 @@
 #include "CCommon.h"
 #include "CMessage.h"
 #include "CMessageExt.h"
+#include "CBatchMessage.h"
 #include "CSendResult.h"
 #include "CProducer.h"
 #include "CPushConsumer.h"
@@ -99,9 +100,11 @@
 void *PyCreateBatchMessage() {
     return (void *) CreateBatchMessage();
 }
+
 int PyAddMessage(void *batchMsg, void *msg) {
     return AddMessage((CBatchMessage *) batchMsg, (CMessage *) msg);
 }
+
 int PyDestroyBatchMessage(void *batchMsg) {
     return DestroyBatchMessage((CBatchMessage *) batchMsg);
 }
@@ -212,7 +215,7 @@
     return SendAsync((CProducer *) producer,  (CMessage *) msg, &PySendSuccessCallback, &PySendExceptionCallback, (void *)pyCallback);
 }
 
-PySendResult PySendBatchMessage(void *producer, CBatchMessage *batchMessage) {
+PySendResult PySendBatchMessage(void *producer, void *batchMessage) {
     PySendResult ret;
     CSendResult result;
     SendBatchMessage((CProducer *) producer, (CBatchMessage *) batchMessage, &result);

src/PythonWrapper.h

diff --git a/src/PythonWrapper.h b/src/PythonWrapper.h
index dc4a519..3224308 100644
--- a/src/PythonWrapper.h
+++ b/src/PythonWrapper.h
@@ -18,6 +18,7 @@
 #include "CCommon.h"
 #include "CMessage.h"
 #include "CMessageExt.h"
+#include "CBatchMessage.h"
 #include "CSendResult.h"
 #include "CProducer.h"
 #include "CPushConsumer.h"
@@ -122,7 +123,7 @@
 void PySendExceptionCallback(CMQException e, CMessage *msg, void *pyCallback);
 int PySendMessageAsync(void *producer, void *msg, PyObject *sendSuccessCallback, PyObject *sendExceptionCallback);
 
-PySendResult PySendBatchMessage(void *producer, CBatchMessage *msg);
+PySendResult PySendBatchMessage(void *producer, void *msg);
 PySendResult PySendMessageOrderly(void *producer, void *msg, int autoRetryTimes, void *args, PyObject *queueSelector);
 PySendResult PySendMessageOrderlyByShardingKey(void *producer, void *msg, const char *shardingKey);