You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2022/04/28 06:13:59 UTC

[rocketmq-apis] 01/02: [ISSUE #26] Make interface orthogonal

This is an automated email from the ASF dual-hosted git repository.

yukon pushed a commit to branch v2
in repository https://gitbox.apache.org/repos/asf/rocketmq-apis.git

commit 19d625860114f9812b8786c863554900353a8933
Author: zhouxiang <zh...@alibaba-inc.com>
AuthorDate: Thu Apr 28 10:42:51 2022 +0800

    [ISSUE #26] Make interface orthogonal
---
 apache/rocketmq/v2/service.proto | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/apache/rocketmq/v2/service.proto b/apache/rocketmq/v2/service.proto
index b9cf533..346b31a 100644
--- a/apache/rocketmq/v2/service.proto
+++ b/apache/rocketmq/v2/service.proto
@@ -46,7 +46,10 @@ option java_outer_classname = "MQService";
 // access-point, which annotates tenant-id, instance-id or other
 // vendor-specific settings. Purpose-built name servers may respond customized
 // results based on these particular requirements.
-message QueryRouteRequest { Resource topic = 1; }
+message QueryRouteRequest {
+  Resource topic = 1;
+  Endpoints endpoints = 2;
+}
 
 message QueryRouteResponse {
   Status status = 1;
@@ -66,6 +69,7 @@ message SendMessageResponse {
 message QueryAssignmentRequest {
   Resource topic = 1;
   Resource group = 2;
+  Endpoints endpoints = 3;
 }
 
 message QueryAssignmentResponse {
@@ -80,6 +84,8 @@ message ReceiveMessageRequest {
   int32 batch_size = 4;
   // Required if client type is simple consumer.
   optional google.protobuf.Duration invisible_duration = 5;
+  // For message auto renew and clean
+  bool auto_renew = 6;
 }
 
 message ReceiveMessageResponse {