Skip to content

Commit da7c0b2

Browse files
authored
[ISSUE #100] Priority Message Proto Definition (#101)
1 parent 2ba7150 commit da7c0b2

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

apache/rocketmq/v2/definition.proto

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -149,6 +149,9 @@ enum MessageType {
149149

150150
// lite topic
151151
LITE = 5;
152+
153+
// Messages that lower prioritised ones may need to wait for higher priority messages to be processed first
154+
PRIORITY = 6;
152155
}
153156

154157
enum DigestType {
@@ -278,6 +281,9 @@ message SystemProperties {
278281

279282
// lite topic
280283
optional string lite_topic = 21;
284+
285+
// Priority of message, which is optional
286+
optional int32 priority = 22;
281287
}
282288

283289
message DeadLetterQueue {

0 commit comments

Comments
 (0)