bundle *reply = bundle_create();
char *info = NULL;
+ char *request_id = NULL;
PyObject* args = NULL;
PyObject* lists = NULL;
unsigned static int len = 0;
PyObject* ld_module = NULL;
PyObject* ld_result = NULL;
PyObject* pos_elm_tuple = NULL;
+ bundle_get_str(msg, "request_id", &request_id);
bundle_get_str(msg, "info", &info);
NLTK_CMDS cmd = NLTK_CMD_NONE;
if (message)
bundle_add_str(reply, "command", "Exception happens");
break;
}
+ bundle_add_str(reply, "request_id", request_id);
rpc_port_message_notify_cb_invoke(sender_client->cb, sender_client->id, reply);
bundle_free(reply);
return 0;