diff options
| author | yangwei <[email protected]> | 2024-07-12 19:47:18 +0800 |
|---|---|---|
| committer | yangwei <[email protected]> | 2024-07-12 20:22:12 +0800 |
| commit | 271e569dbf8a58e36a357226b585a15515655b15 (patch) | |
| tree | 19c0c6ee13c69b5281a7d8ddfcca9c17617c1b9f /include | |
| parent | 0913c1cd4bcc8e9f682902c9babe5a66f672121e (diff) | |
✨ feat(session mq with priority): support 3 priority mq, default to normalFeature-session-mq-priority
Diffstat (limited to 'include')
| -rw-r--r-- | include/stellar/session_mq.h | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/include/stellar/session_mq.h b/include/stellar/session_mq.h index a3a631a..3c62f69 100644 --- a/include/stellar/session_mq.h +++ b/include/stellar/session_mq.h @@ -23,4 +23,14 @@ int session_mq_publish_message(struct session *sess, int topic_id, void *msg); int session_mq_ignore_message(struct session *sess, int topic_id, int plugin_id); int session_mq_unignore_message(struct session *sess, int topic_id, int plugin_id); -int session_mq_topic_is_active(struct session *sess, int topic_id);
\ No newline at end of file +int session_mq_topic_is_active(struct session *sess, int topic_id); + +enum session_mq_priority +{ + SESSION_MQ_PRIORITY_LOW, + SESSION_MQ_PRIORITY_NORMAL, + SESSION_MQ_PRIORITY_HIGH, + SESSION_MQ_PRIORITY_MAX, +}; + +int session_mq_publish_message_with_priority(struct session *sess, int topic_id, void *msg, enum session_mq_priority priority);
\ No newline at end of file |