diff options
| author | yangwei <[email protected]> | 2024-09-06 13:31:29 +0800 |
|---|---|---|
| committer | yangwei <[email protected]> | 2024-09-06 19:48:29 +0800 |
| commit | cc542dc36538a8dd977a12c739f9c307c9e0b321 (patch) | |
| tree | 4beccef8cf567f611c95a6f83f986007403a386c /include | |
| parent | 442586ef52c5c6fb589651d9889e14cbfcdc1ba7 (diff) | |
✨ feat(stellar mq topic api): add dispatch_cb_arg for dispatch_cb
Diffstat (limited to 'include')
| -rw-r--r-- | include/stellar/stellar_mq.h | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/include/stellar/stellar_mq.h b/include/stellar/stellar_mq.h index b2a5f44..7856719 100644 --- a/include/stellar/stellar_mq.h +++ b/include/stellar/stellar_mq.h @@ -17,12 +17,12 @@ inline static void stellar_msg_free_default(void *msg, void *msg_free_arg __unus } typedef void on_msg_cb_func(int topic_id, const void *msg, void *plugin_env); -typedef void on_msg_dispatch_cb_func(int topic_id, const void *msg, on_msg_cb_func* on_msg_cb, void *sub_plugin_env); +typedef void on_msg_dispatch_cb_func(int topic_id, const void *msg, on_msg_cb_func* on_msg_cb, void *dispatch_arg, void *sub_plugin_env); //return topic_id -int stellar_mq_create_topic(struct stellar *st, const char *topic_name, on_msg_dispatch_cb_func *on_dispatch_cb, stellar_msg_free_cb_func *msg_free_cb, void *msg_free_arg); +int stellar_mq_create_topic(struct stellar *st, const char *topic_name, on_msg_dispatch_cb_func *on_dispatch_cb, void *on_dispatch_arg, stellar_msg_free_cb_func *msg_free_cb, void *msg_free_arg); int stellar_mq_get_topic_id(struct stellar *st, const char *topic_name); -int stellar_mq_update_topic(struct stellar *st, int topic_id, on_msg_dispatch_cb_func *on_dispatch_cb, stellar_msg_free_cb_func *msg_free_cb, void *msg_free_arg); +int stellar_mq_update_topic(struct stellar *st, int topic_id, on_msg_dispatch_cb_func *on_dispatch_cb, void *on_dispatch_arg, stellar_msg_free_cb_func *msg_free_cb, void *msg_free_arg); int stellar_mq_destroy_topic(struct stellar *st, int topic_id); |