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 {