You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2022/03/29 01:56:32 UTC

[rocketmq-apis] branch v2 updated: Rename some of the code

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 c8c959b  Rename some of the code
c8c959b is described below

commit c8c959b789a062fa954a9aae61343a7c7b551b4a
Author: Li Zhanhui <li...@gmail.com>
AuthorDate: Tue Mar 29 01:56:24 2022 +0000

    Rename some of the code
---
 apache/rocketmq/v2/definition.proto | 63 +++++++++++++++++++++++++++++++++++++
 apache/rocketmq/v2/service.proto    | 50 -----------------------------
 2 files changed, 63 insertions(+), 50 deletions(-)

diff --git a/apache/rocketmq/v2/definition.proto b/apache/rocketmq/v2/definition.proto
index d04f761..cedc91c 100644
--- a/apache/rocketmq/v2/definition.proto
+++ b/apache/rocketmq/v2/definition.proto
@@ -384,4 +384,67 @@ enum QueryOffsetPolicy {
 message SendReceipt {
   string message_id = 1;
   string transaction_id = 2;
+}
+
+enum Code {
+  // Success.
+  OK = 0;
+  // Format of access point is illegal.
+  ILLEGAL_ACCESS_POINT = 1;
+  // Format of topic is illegal.
+  ILLEGAL_TOPIC = 2;
+  // Format of consumer group is illegal.
+  ILLEGAL_CONSUMER_GROUP = 3;
+  // Format of message tag is illegal.
+  ILLEGAL_MESSAGE_TAG = 4;
+  // Format of message key is illegal.
+  ILLEGAL_MESSAGE_KEY = 5;
+  // Size of message keys exceeds the threshold.
+  MESSAGE_KEYS_TOO_LARGE = 6;
+  // Format of message group is illegal.
+  ILLEGAL_MESSAGE_GROUP = 7;
+  // Format of message property key is illegal.
+  ILLEGAL_MESSAGE_PROPERTY_KEY = 8;
+  // Message properties total size exceeds the threshold.
+  MESSAGE_PROPERTIES_TOO_LARGE = 9;
+  // Message body size exceeds the threshold.
+  MESSAGE_BODY_TOO_LARGE = 10;
+
+  // User does not have the permission to operate. Forbidden.
+  ACCESS_DENIED = 11;
+
+  // Identity could not be recognized.
+  AUTHENTICATION_REQUIRED = 12;
+
+  // Topic resource does not exist.
+  TOPIC_NOT_FOUND = 13;
+
+  // Consumer group resource does not exist.
+  CONSUMER_GROUP_NOT_FOUND = 14;
+
+  // Not allowed to verify message. Chances are that you are verifying
+  // a FIFO message, as is violating FIFO semantics.
+  VERIFY_MESSAGE_FORBIDDEN = 15;
+
+  // Failed to consume message.
+  FAILED_TO_CONSUME_MESSAGE = 16;
+
+  // Message is corrupted.
+  MESSAGE_CORRUPTED = 17;
+
+  // Too many requests are made in short period of duration.
+  // Requests are throttled.
+  TOO_MANY_REQUESTS = 18;
+
+  // Expired receip-handle is used when trying to acknowledge or change
+  // invisible duration of a message
+  RECEIPT_HANDLE_EXPIRED = 19;
+
+  // Message property is not match the message type.
+  MESSAGE_PROPERTY_DOES_NOT_MATCH_MESSAGE_TYPE = 20;
+}
+
+message Status {
+  Code code = 1;
+  string message = 2;
 }
\ No newline at end of file
diff --git a/apache/rocketmq/v2/service.proto b/apache/rocketmq/v2/service.proto
index 6cd2a94..01615cd 100644
--- a/apache/rocketmq/v2/service.proto
+++ b/apache/rocketmq/v2/service.proto
@@ -31,56 +31,6 @@ option java_generate_equals_and_hash = true;
 option java_string_check_utf8 = true;
 option java_outer_classname = "MQService";
 
-enum ResponseCode {
-  // Success.
-  OK = 0;
-  // Format of access point is illegal.
-  ILLEGAL_ACCESS_POINT = 1;
-  // Format of topic is illegal.
-  ILLEGAL_TOPIC = 2;
-  // Format of consumer group is illegal.
-  ILLEGAL_CONSUMER_GROUP = 3;
-  // Format of message tag is illegal.
-  ILLEGAL_MESSAGE_TAG = 4;
-  // Format of message key is illegal.
-  ILLEGAL_MESSAGE_KEY = 5;
-  // Size of message keys exceeds the threshold.
-  MESSAGE_KEYS_TOO_LARGE = 6;
-  // Format of message group is illegal.
-  ILLEGAL_MESSAGE_GROUP = 7;
-  // Format of message property key is illegal.
-  ILLEGAL_MESSAGE_PROPERTY_KEY = 8;
-  // Message properties total size exceeds the threshold.
-  MESSAGE_PROPERTIES_TOO_LARGE = 9;
-  // Message body size exceeds the threshold.
-  MESSAGE_BODY_TOO_LARGE = 10;
-  // User does have the permission to operate.
-  REQUEST_AUTHORISATION_FAILURE = 11;
-  // User's identity could not be recognized.
-  REQUEST_AUTHENTICATION_FAILURE = 12;
-  // Topic resource does not exist.
-  TOPIC_DOES_NOT_EXIST = 13;
-  // Consumer group resource does not exist.
-  CONSUMER_GROUP_DOES_NOT_EXIST = 14;
-  // Not allowed to verify message.
-  VERIFY_MESSAGE_NOT_ALLOWED = 15;
-  // Failed to consume message.
-  FAILED_TO_CONSUME_MESSAGE = 16;
-  // Message is corrupted.
-  MESSAGE_CORRUPTED = 17;
-  // Flow control.
-  REQUEST_FLOW_CONTROL = 18;
-  // Ack request is expired.
-  ACKNOWLEDGEMENT_EXPIRED = 19;
-  // Message property is not match the message type.
-  MESSAGE_PROPERTY_DOES_NOT_MATCH_MESSAGE_TYPE = 20;
-}
-
-message Status {
-  ResponseCode code = 1;
-  string message = 2;
-}
-
 // Topics are destination of messages to publish to or subscribe from. Similar
 // to domain names, they will be addressable after resolution through the
 // provided access point.