This is an automated email from the ASF dual-hosted git repository.
lizhanhui 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 7ed3e26 add dlq information to message's systemProperties (#64)
7ed3e26 is described below
commit 7ed3e267292ea971064d86acee47a8ef60181121
Author: Jixiang Jin <[email protected]>
AuthorDate: Mon Oct 10 19:35:28 2022 +0800
add dlq information to message's systemProperties (#64)
* add dlq information to message's systemProperties
* do the rename work
* do the rename work
---
apache/rocketmq/v2/definition.proto | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/apache/rocketmq/v2/definition.proto
b/apache/rocketmq/v2/definition.proto
index f0a637d..d10418d 100644
--- a/apache/rocketmq/v2/definition.proto
+++ b/apache/rocketmq/v2/definition.proto
@@ -266,6 +266,16 @@ message SystemProperties {
// orphan. Servers that manages orphan messages would pick up
// a capable publisher to resolve
optional google.protobuf.Duration orphaned_transaction_recovery_duration =
19;
+
+ // Information to identify whether this message is from dead letter queue.
+ optional DeadLetterQueue dead_letter_queue = 20;
+}
+
+message DeadLetterQueue {
+ // Original topic for this DLQ message.
+ string topic = 1;
+ // Original message id for this DLQ message.
+ string message_id = 2;
}
message Message {
