[rocketmq-apis] branch v2 updated: Polish code (#23)

[li...@apache.org]

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 e98dd18  Polish code (#23)
e98dd18 is described below

commit e98dd18b61712cf4272c5494d2a9062451734fd2
Author: Aaron Ai <ya...@alibaba-inc.com>
AuthorDate: Fri Apr 22 12:01:30 2022 +0800

    Polish code (#23)
---
 apache/rocketmq/v2/definition.proto | 1 +
 apache/rocketmq/v2/service.proto    | 9 +++------
 2 files changed, 4 insertions(+), 6 deletions(-)

diff --git a/apache/rocketmq/v2/definition.proto b/apache/rocketmq/v2/definition.proto
index 94c64b4..aa12be1 100644
--- a/apache/rocketmq/v2/definition.proto
+++ b/apache/rocketmq/v2/definition.proto
@@ -63,6 +63,7 @@ message RetryPolicy {
   float initial_backoff = 2;
   float max_backoff = 3;
   float backoff_multiplier = 4;
+  bool random = 5;
 }
 
 message Resource {
diff --git a/apache/rocketmq/v2/service.proto b/apache/rocketmq/v2/service.proto
index 58761e7..1cf7869 100644
--- a/apache/rocketmq/v2/service.proto
+++ b/apache/rocketmq/v2/service.proto
@@ -222,23 +222,20 @@ message Subscription {
   // ones are completely acknowledged.
   optional bool fifo = 3;
 
-  // Max delivery attempts.
-  optional int32 max_delivery_attempts = 4;
-
   // When processing message fails, `backoff_policy` describes an interval
   // after which the message is ready to consume again.
   //
   // For FIFO messages, the interval should be relatively small because
   // messages of the same message group would not be readily available utill
   // the prior one depletes its lifecycle.
-  RetryPolicy backoff_policy = 5;
+  optional RetryPolicy backoff_policy = 4;
 
   // Message receive batch size here is essential for push consumer.
-  optional int32 receive_batch_size = 6;
+  optional int32 receive_batch_size = 5;
 
   // Long-polling timeout for `ReceiveMessageRequest`, which is essential for
   // push consumer.
-  optional google.protobuf.Duration long_polling_timeout = 7;
+  optional google.protobuf.Duration long_polling_timeout = 6;
 }
 
 message Settings {