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 <[email protected]> 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 {
