You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2022/03/21 08:06:47 UTC
[rocketmq-apis] branch v2 updated: Move FIFO flag to ConsumerData
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch v2
in repository https://gitbox.apache.org/repos/asf/rocketmq-apis.git
The following commit(s) were added to refs/heads/v2 by this push:
new e8cd398 Move FIFO flag to ConsumerData
e8cd398 is described below
commit e8cd3986065b54256ac844de33434f99bb0b7d6a
Author: Li Zhanhui <li...@gmail.com>
AuthorDate: Mon Mar 21 08:06:40 2022 +0000
Move FIFO flag to ConsumerData
---
apache/rocketmq/v2/definition.proto | 2 ++
apache/rocketmq/v2/service.proto | 3 +--
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/apache/rocketmq/v2/definition.proto b/apache/rocketmq/v2/definition.proto
index 27ed3b5..e20c2f6 100644
--- a/apache/rocketmq/v2/definition.proto
+++ b/apache/rocketmq/v2/definition.proto
@@ -114,6 +114,8 @@ message ConsumerData {
DeadLetterPolicy dead_letter_policy = 4;
ConsumeMessageType consume_type = 5;
+
+ bool fifo = 6;
}
message SubscriptionEntry {
diff --git a/apache/rocketmq/v2/service.proto b/apache/rocketmq/v2/service.proto
index 2864f54..9eeb2b7 100644
--- a/apache/rocketmq/v2/service.proto
+++ b/apache/rocketmq/v2/service.proto
@@ -144,8 +144,7 @@ message ForwardMessageToDeadLetterQueueResponse {
message HeartbeatRequest {
string client_id = 1;
- ConsumerData consumer_data = 2;
- bool fifo_flag = 3;
+ ConsumerData data = 2;
}
message HeartbeatResponse {