This is an automated email from the ASF dual-hosted git repository.
lizhimin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-apis.git
The following commit(s) were added to refs/heads/main by this push:
new da7c0b2 [ISSUE #100] Priority Message Proto Definition (#101)
da7c0b2 is described below
commit da7c0b23cc43df7947ba9a308c51dd6e73e057fb
Author: imzs <[email protected]>
AuthorDate: Wed Dec 10 15:34:54 2025 +0800
[ISSUE #100] Priority Message Proto Definition (#101)
---
apache/rocketmq/v2/definition.proto | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/apache/rocketmq/v2/definition.proto
b/apache/rocketmq/v2/definition.proto
index a0d3dfe..516474d 100644
--- a/apache/rocketmq/v2/definition.proto
+++ b/apache/rocketmq/v2/definition.proto
@@ -149,6 +149,9 @@ enum MessageType {
// lite topic
LITE = 5;
+
+ // Messages that lower prioritised ones may need to wait for higher priority
messages to be processed first
+ PRIORITY = 6;
}
enum DigestType {
@@ -278,6 +281,9 @@ message SystemProperties {
// lite topic
optional string lite_topic = 21;
+
+ // Priority of message, which is optional
+ optional int32 priority = 22;
}
message DeadLetterQueue {
