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:58 UTC
[rocketmq-apis] branch v2 updated (71f65c3 -> 4287247)
This is an automated email from the ASF dual-hosted git repository.
yukon pushed a change to branch v2
in repository https://gitbox.apache.org/repos/asf/rocketmq-apis.git
from 71f65c3 Externalize backoff configuration for retries
new 19d6258 [ISSUE #26] Make interface orthogonal
new 4287247 Add message_id in ChangeInvisibleDurationRequest for tracing
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
apache/rocketmq/v2/service.proto | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
[rocketmq-apis] 01/02: [ISSUE #26] Make interface orthogonal
Posted by yu...@apache.org.
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 {
[rocketmq-apis] 02/02: Add message_id in ChangeInvisibleDurationRequest for tracing
Posted by yu...@apache.org.
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 4287247ae6f2e06f9150cfecb6c2d013af0b10a8
Author: zhouxiang <zh...@alibaba-inc.com>
AuthorDate: Thu Apr 28 11:07:58 2022 +0800
Add message_id in ChangeInvisibleDurationRequest for tracing
---
apache/rocketmq/v2/service.proto | 3 +++
1 file changed, 3 insertions(+)
diff --git a/apache/rocketmq/v2/service.proto b/apache/rocketmq/v2/service.proto
index 346b31a..d5991ed 100644
--- a/apache/rocketmq/v2/service.proto
+++ b/apache/rocketmq/v2/service.proto
@@ -296,6 +296,9 @@ message ChangeInvisibleDurationRequest {
// New invisible duration
google.protobuf.Duration invisible_duration = 4;
+
+ // For message tracing
+ string message_id = 5;
}
message ChangeInvisibleDurationResponse {