Skip to content

Add support for async send message and shardingkey order message #48

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
ShannonDing merged 13 commits into from
Oct 11, 2019
Merged

Add support for async send message and shardingkey order message #48

Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
30d6b53
feat(producer) add send message orderly by sharding key
duhenglucky Sep 26, 2019
a505be2
fix(producer) remove useless parameter in send message orderly
duhenglucky Sep 26, 2019
d216bdf
feature(producer) add async send message for producer
duhenglucky Sep 29, 2019
07c42cd
fix(producer) fix the call back map redefinition error
duhenglucky Sep 29, 2019
cb4347f
feat(producer) add compress and max message size set support
duhenglucky Oct 9, 2019
5c55173
feat(producer) polish async send message
duhenglucky Oct 9, 2019
88a432a
fix(producer) fix send message call back delcare error
duhenglucky Oct 9, 2019
35498a5
fix(producer) remove Message convert
duhenglucky Oct 9, 2019
44406b2
feat(producer) add thread lock for send message async
duhenglucky Oct 10, 2019
72ffeeb
fix(producer) polish async send callback implementation
duhenglucky Oct 10, 2019
e48b369
test(producer) add async send message test
duhenglucky Oct 10, 2019
37bc0bc
feat(producer) add exception mechanism for send message
duhenglucky Oct 10, 2019
d905905
test(producer) add exception test in async send message
duhenglucky Oct 10, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
fix(producer) polish async send callback implementation
  • Loading branch information
@duhenglucky
duhenglucky committed Oct 10, 2019
commit 72ffeeb5830f0303292e5e62e7a7241b110e4e3d
8 changes: 6 additions & 2 deletions src/PythonWrapper.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -173,18 +173,22 @@ void PySendSuccessCallback(CSendResult result, CMessage *msg, void *pyCallback){
sendResult.msgId[MAX_MESSAGE_ID_LENGTH - 1] = 0;
PyCallback *callback = (PyCallback *)pyCallback;
boost::python::call<void>(callback->successCallback, sendResult, (void *) msg);
delete pyCallback;
}


void PySendExceptionCallback(CMQException e, CMessage *msg, void *pyCallback){
PyThreadStateLock PyThreadLock; // ensure hold GIL, before call python callback
PyCallback *callback = (PyCallback *)pyCallback;
boost::python::call<void>(callback->exceptionCallback, (void *) msg, e);
delete pyCallback;
}

int PySendMessageAsync(void *producer, void *msg, PyObject *sendSuccessCallback, PyObject *sendExceptionCallback){
PyCallback pyCallback = {sendSuccessCallback, sendExceptionCallback};
return SendAsync((CProducer *) producer, (CMessage *) msg, &PySendSuccessCallback, &PySendExceptionCallback, &pyCallback);
PyCallback* pyCallback = new PyCallback();
pyCallback->successCallback = sendSuccessCallback;
pyCallback->exceptionCallback = sendExceptionCallback;
return SendAsync((CProducer *) producer, (CMessage *) msg, &PySendSuccessCallback, &PySendExceptionCallback, (void *)pyCallback);
}


Expand Down