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 {