This is an automated email from the ASF dual-hosted git repository. aaronai pushed a commit to branch java in repository https://gitbox.apache.org/repos/asf/rocketmq-apis.git
commit d6ebb3f51eac723fa2da4658f455f8994465a94a Author: 凌楚 <[email protected]> AuthorDate: Thu Jun 30 15:02:16 2022 +0800 Apply IDL update --- src/main/java/apache/rocketmq/v2/Code.java | 276 +++++++++++++-------- src/main/java/apache/rocketmq/v2/MQDomain.java | 55 ++-- .../proto/apache/rocketmq/v2/definition.proto | 55 ++-- 3 files changed, 243 insertions(+), 143 deletions(-) diff --git a/src/main/java/apache/rocketmq/v2/Code.java b/src/main/java/apache/rocketmq/v2/Code.java index 8f2f7c7..d0b14c6 100644 --- a/src/main/java/apache/rocketmq/v2/Code.java +++ b/src/main/java/apache/rocketmq/v2/Code.java @@ -92,86 +92,70 @@ public enum Code * <code>ILLEGAL_MESSAGE_PROPERTY_KEY = 40007;</code> */ ILLEGAL_MESSAGE_PROPERTY_KEY(40007), - /** - * <pre> - * Message properties total size exceeds the threshold. - * </pre> - * - * <code>MESSAGE_PROPERTIES_TOO_LARGE = 40008;</code> - */ - MESSAGE_PROPERTIES_TOO_LARGE(40008), - /** - * <pre> - * Message body size exceeds the threshold. - * </pre> - * - * <code>MESSAGE_BODY_TOO_LARGE = 40009;</code> - */ - MESSAGE_BODY_TOO_LARGE(40009), /** * <pre> * Transaction id is invalid. * </pre> * - * <code>INVALID_TRANSACTION_ID = 40010;</code> + * <code>INVALID_TRANSACTION_ID = 40008;</code> */ - INVALID_TRANSACTION_ID(40010), + INVALID_TRANSACTION_ID(40008), /** * <pre> * Format of message id is illegal. * </pre> * - * <code>ILLEGAL_MESSAGE_ID = 40011;</code> + * <code>ILLEGAL_MESSAGE_ID = 40009;</code> */ - ILLEGAL_MESSAGE_ID(40011), + ILLEGAL_MESSAGE_ID(40009), /** * <pre> * Format of filter expression is illegal. * </pre> * - * <code>ILLEGAL_FILTER_EXPRESSION = 40012;</code> + * <code>ILLEGAL_FILTER_EXPRESSION = 40010;</code> */ - ILLEGAL_FILTER_EXPRESSION(40012), + ILLEGAL_FILTER_EXPRESSION(40010), /** * <pre> * Receipt handle of message is invalid. * </pre> * - * <code>INVALID_RECEIPT_HANDLE = 40013;</code> + * <code>INVALID_RECEIPT_HANDLE = 40011;</code> */ - INVALID_RECEIPT_HANDLE(40013), + INVALID_RECEIPT_HANDLE(40011), /** * <pre> - * Message property is not match the message type. + * Message property conflicts with its type. * </pre> * - * <code>MESSAGE_PROPERTY_DOES_NOT_MATCH_MESSAGE_TYPE = 40014;</code> + * <code>MESSAGE_PROPERTY_CONFLICT_WITH_TYPE = 40012;</code> */ - MESSAGE_PROPERTY_DOES_NOT_MATCH_MESSAGE_TYPE(40014), + MESSAGE_PROPERTY_CONFLICT_WITH_TYPE(40012), /** * <pre> * Client type could not be recognized. * </pre> * - * <code>UNRECOGNIZED_CLIENT_TYPE = 40015;</code> + * <code>UNRECOGNIZED_CLIENT_TYPE = 40013;</code> */ - UNRECOGNIZED_CLIENT_TYPE(40015), + UNRECOGNIZED_CLIENT_TYPE(40013), /** * <pre> * Message is corrupted. * </pre> * - * <code>MESSAGE_CORRUPTED = 40016;</code> + * <code>MESSAGE_CORRUPTED = 40014;</code> */ - MESSAGE_CORRUPTED(40016), + MESSAGE_CORRUPTED(40014), /** * <pre> * Request is rejected due to missing of x-mq-client-id header. * </pre> * - * <code>CLIENT_ID_REQUIRED = 40017;</code> + * <code>CLIENT_ID_REQUIRED = 40015;</code> */ - CLIENT_ID_REQUIRED(40017), + CLIENT_ID_REQUIRED(40015), /** * <pre> * Generic code indicates that the client request lacks valid authentication @@ -181,6 +165,14 @@ public enum Code * <code>UNAUTHORIZED = 40100;</code> */ UNAUTHORIZED(40100), + /** + * <pre> + * Generic code indicates that the account is suspended due to overdue of payment. + * </pre> + * + * <code>PAYMENT_REQUIRED = 40200;</code> + */ + PAYMENT_REQUIRED(40200), /** * <pre> * Generic code for the case that user does not have the permission to operate. @@ -221,6 +213,40 @@ public enum Code * <code>CONSUMER_GROUP_NOT_FOUND = 40403;</code> */ CONSUMER_GROUP_NOT_FOUND(40403), + /** + * <pre> + * Generic code representing client side timeout when connecting to, reading data from, or write data to server. + * </pre> + * + * <code>REQUEST_TIMEOUT = 40800;</code> + */ + REQUEST_TIMEOUT(40800), + /** + * <pre> + * Generic code represents that the request entity is larger than limits defined by server. + * </pre> + * + * <code>PAYLOAD_TOO_LARGE = 41300;</code> + */ + PAYLOAD_TOO_LARGE(41300), + /** + * <pre> + * Message body size exceeds the threshold. + * </pre> + * + * <code>MESSAGE_BODY_TOO_LARGE = 41301;</code> + */ + MESSAGE_BODY_TOO_LARGE(41301), + /** + * <pre> + * Generic code for use cases where pre-conditions are not met. + * For example, if a producer instance is used to publish messages without prior start() invocation, + * this error code will be raised. + * </pre> + * + * <code>PRECONDITION_FAILED = 42800;</code> + */ + PRECONDITION_FAILED(42800), /** * <pre> * Generic code indicates that too many requests are made in short period of duration. @@ -230,6 +256,23 @@ public enum Code * <code>TOO_MANY_REQUESTS = 42900;</code> */ TOO_MANY_REQUESTS(42900), + /** + * <pre> + * Generic code for the case that the server is unwilling to process the request because its header fields are too large. + * The request may be resubmitted after reducing the size of the request header fields. + * </pre> + * + * <code>REQUEST_HEADER_FIELDS_TOO_LARGE = 43100;</code> + */ + REQUEST_HEADER_FIELDS_TOO_LARGE(43100), + /** + * <pre> + * Message properties total size exceeds the threshold. + * </pre> + * + * <code>MESSAGE_PROPERTIES_TOO_LARGE = 43101;</code> + */ + MESSAGE_PROPERTIES_TOO_LARGE(43101), /** * <pre> * Generic code indicates that server/client encountered an unexpected @@ -273,12 +316,13 @@ public enum Code NOT_IMPLEMENTED(50100), /** * <pre> - * Generic code for timeout. + * Generic code represents that the server, which acts as a gateway or proxy, + * does not get an satisfied response in time from its upstream servers. * </pre> * - * <code>TIMEOUT = 50400;</code> + * <code>PROXY_TIMEOUT = 50400;</code> */ - TIMEOUT(50400), + PROXY_TIMEOUT(50400), /** * <pre> * Message persistence timeout. @@ -297,15 +341,9 @@ public enum Code SLAVE_PERSISTENCE_TIMEOUT(50402), /** * <pre> - * Code indicates that the server, while acting as a gateway or proxy, - * did not get a response in time from the upstream server that - * it needed in order to complete the request. + * Generic code for unsupported operation. * </pre> * - * <code>PROXY_TIMEOUT = 50403;</code> - */ - PROXY_TIMEOUT(50403), - /** * <code>UNSUPPORTED = 50500;</code> */ UNSUPPORTED(50500), @@ -421,86 +459,70 @@ public enum Code * <code>ILLEGAL_MESSAGE_PROPERTY_KEY = 40007;</code> */ public static final int ILLEGAL_MESSAGE_PROPERTY_KEY_VALUE = 40007; - /** - * <pre> - * Message properties total size exceeds the threshold. - * </pre> - * - * <code>MESSAGE_PROPERTIES_TOO_LARGE = 40008;</code> - */ - public static final int MESSAGE_PROPERTIES_TOO_LARGE_VALUE = 40008; - /** - * <pre> - * Message body size exceeds the threshold. - * </pre> - * - * <code>MESSAGE_BODY_TOO_LARGE = 40009;</code> - */ - public static final int MESSAGE_BODY_TOO_LARGE_VALUE = 40009; /** * <pre> * Transaction id is invalid. * </pre> * - * <code>INVALID_TRANSACTION_ID = 40010;</code> + * <code>INVALID_TRANSACTION_ID = 40008;</code> */ - public static final int INVALID_TRANSACTION_ID_VALUE = 40010; + public static final int INVALID_TRANSACTION_ID_VALUE = 40008; /** * <pre> * Format of message id is illegal. * </pre> * - * <code>ILLEGAL_MESSAGE_ID = 40011;</code> + * <code>ILLEGAL_MESSAGE_ID = 40009;</code> */ - public static final int ILLEGAL_MESSAGE_ID_VALUE = 40011; + public static final int ILLEGAL_MESSAGE_ID_VALUE = 40009; /** * <pre> * Format of filter expression is illegal. * </pre> * - * <code>ILLEGAL_FILTER_EXPRESSION = 40012;</code> + * <code>ILLEGAL_FILTER_EXPRESSION = 40010;</code> */ - public static final int ILLEGAL_FILTER_EXPRESSION_VALUE = 40012; + public static final int ILLEGAL_FILTER_EXPRESSION_VALUE = 40010; /** * <pre> * Receipt handle of message is invalid. * </pre> * - * <code>INVALID_RECEIPT_HANDLE = 40013;</code> + * <code>INVALID_RECEIPT_HANDLE = 40011;</code> */ - public static final int INVALID_RECEIPT_HANDLE_VALUE = 40013; + public static final int INVALID_RECEIPT_HANDLE_VALUE = 40011; /** * <pre> - * Message property is not match the message type. + * Message property conflicts with its type. * </pre> * - * <code>MESSAGE_PROPERTY_DOES_NOT_MATCH_MESSAGE_TYPE = 40014;</code> + * <code>MESSAGE_PROPERTY_CONFLICT_WITH_TYPE = 40012;</code> */ - public static final int MESSAGE_PROPERTY_DOES_NOT_MATCH_MESSAGE_TYPE_VALUE = 40014; + public static final int MESSAGE_PROPERTY_CONFLICT_WITH_TYPE_VALUE = 40012; /** * <pre> * Client type could not be recognized. * </pre> * - * <code>UNRECOGNIZED_CLIENT_TYPE = 40015;</code> + * <code>UNRECOGNIZED_CLIENT_TYPE = 40013;</code> */ - public static final int UNRECOGNIZED_CLIENT_TYPE_VALUE = 40015; + public static final int UNRECOGNIZED_CLIENT_TYPE_VALUE = 40013; /** * <pre> * Message is corrupted. * </pre> * - * <code>MESSAGE_CORRUPTED = 40016;</code> + * <code>MESSAGE_CORRUPTED = 40014;</code> */ - public static final int MESSAGE_CORRUPTED_VALUE = 40016; + public static final int MESSAGE_CORRUPTED_VALUE = 40014; /** * <pre> * Request is rejected due to missing of x-mq-client-id header. * </pre> * - * <code>CLIENT_ID_REQUIRED = 40017;</code> + * <code>CLIENT_ID_REQUIRED = 40015;</code> */ - public static final int CLIENT_ID_REQUIRED_VALUE = 40017; + public static final int CLIENT_ID_REQUIRED_VALUE = 40015; /** * <pre> * Generic code indicates that the client request lacks valid authentication @@ -510,6 +532,14 @@ public enum Code * <code>UNAUTHORIZED = 40100;</code> */ public static final int UNAUTHORIZED_VALUE = 40100; + /** + * <pre> + * Generic code indicates that the account is suspended due to overdue of payment. + * </pre> + * + * <code>PAYMENT_REQUIRED = 40200;</code> + */ + public static final int PAYMENT_REQUIRED_VALUE = 40200; /** * <pre> * Generic code for the case that user does not have the permission to operate. @@ -550,6 +580,40 @@ public enum Code * <code>CONSUMER_GROUP_NOT_FOUND = 40403;</code> */ public static final int CONSUMER_GROUP_NOT_FOUND_VALUE = 40403; + /** + * <pre> + * Generic code representing client side timeout when connecting to, reading data from, or write data to server. + * </pre> + * + * <code>REQUEST_TIMEOUT = 40800;</code> + */ + public static final int REQUEST_TIMEOUT_VALUE = 40800; + /** + * <pre> + * Generic code represents that the request entity is larger than limits defined by server. + * </pre> + * + * <code>PAYLOAD_TOO_LARGE = 41300;</code> + */ + public static final int PAYLOAD_TOO_LARGE_VALUE = 41300; + /** + * <pre> + * Message body size exceeds the threshold. + * </pre> + * + * <code>MESSAGE_BODY_TOO_LARGE = 41301;</code> + */ + public static final int MESSAGE_BODY_TOO_LARGE_VALUE = 41301; + /** + * <pre> + * Generic code for use cases where pre-conditions are not met. + * For example, if a producer instance is used to publish messages without prior start() invocation, + * this error code will be raised. + * </pre> + * + * <code>PRECONDITION_FAILED = 42800;</code> + */ + public static final int PRECONDITION_FAILED_VALUE = 42800; /** * <pre> * Generic code indicates that too many requests are made in short period of duration. @@ -559,6 +623,23 @@ public enum Code * <code>TOO_MANY_REQUESTS = 42900;</code> */ public static final int TOO_MANY_REQUESTS_VALUE = 42900; + /** + * <pre> + * Generic code for the case that the server is unwilling to process the request because its header fields are too large. + * The request may be resubmitted after reducing the size of the request header fields. + * </pre> + * + * <code>REQUEST_HEADER_FIELDS_TOO_LARGE = 43100;</code> + */ + public static final int REQUEST_HEADER_FIELDS_TOO_LARGE_VALUE = 43100; + /** + * <pre> + * Message properties total size exceeds the threshold. + * </pre> + * + * <code>MESSAGE_PROPERTIES_TOO_LARGE = 43101;</code> + */ + public static final int MESSAGE_PROPERTIES_TOO_LARGE_VALUE = 43101; /** * <pre> * Generic code indicates that server/client encountered an unexpected @@ -602,12 +683,13 @@ public enum Code public static final int NOT_IMPLEMENTED_VALUE = 50100; /** * <pre> - * Generic code for timeout. + * Generic code represents that the server, which acts as a gateway or proxy, + * does not get an satisfied response in time from its upstream servers. * </pre> * - * <code>TIMEOUT = 50400;</code> + * <code>PROXY_TIMEOUT = 50400;</code> */ - public static final int TIMEOUT_VALUE = 50400; + public static final int PROXY_TIMEOUT_VALUE = 50400; /** * <pre> * Message persistence timeout. @@ -626,15 +708,9 @@ public enum Code public static final int SLAVE_PERSISTENCE_TIMEOUT_VALUE = 50402; /** * <pre> - * Code indicates that the server, while acting as a gateway or proxy, - * did not get a response in time from the upstream server that - * it needed in order to complete the request. + * Generic code for unsupported operation. * </pre> * - * <code>PROXY_TIMEOUT = 50403;</code> - */ - public static final int PROXY_TIMEOUT_VALUE = 50403; - /** * <code>UNSUPPORTED = 50500;</code> */ public static final int UNSUPPORTED_VALUE = 50500; @@ -700,31 +776,35 @@ public enum Code case 40005: return ILLEGAL_MESSAGE_KEY; case 40006: return ILLEGAL_MESSAGE_GROUP; case 40007: return ILLEGAL_MESSAGE_PROPERTY_KEY; - case 40008: return MESSAGE_PROPERTIES_TOO_LARGE; - case 40009: return MESSAGE_BODY_TOO_LARGE; - case 40010: return INVALID_TRANSACTION_ID; - case 40011: return ILLEGAL_MESSAGE_ID; - case 40012: return ILLEGAL_FILTER_EXPRESSION; - case 40013: return INVALID_RECEIPT_HANDLE; - case 40014: return MESSAGE_PROPERTY_DOES_NOT_MATCH_MESSAGE_TYPE; - case 40015: return UNRECOGNIZED_CLIENT_TYPE; - case 40016: return MESSAGE_CORRUPTED; - case 40017: return CLIENT_ID_REQUIRED; + case 40008: return INVALID_TRANSACTION_ID; + case 40009: return ILLEGAL_MESSAGE_ID; + case 40010: return ILLEGAL_FILTER_EXPRESSION; + case 40011: return INVALID_RECEIPT_HANDLE; + case 40012: return MESSAGE_PROPERTY_CONFLICT_WITH_TYPE; + case 40013: return UNRECOGNIZED_CLIENT_TYPE; + case 40014: return MESSAGE_CORRUPTED; + case 40015: return CLIENT_ID_REQUIRED; case 40100: return UNAUTHORIZED; + case 40200: return PAYMENT_REQUIRED; case 40300: return FORBIDDEN; case 40400: return NOT_FOUND; case 40401: return MESSAGE_NOT_FOUND; case 40402: return TOPIC_NOT_FOUND; case 40403: return CONSUMER_GROUP_NOT_FOUND; + case 40800: return REQUEST_TIMEOUT; + case 41300: return PAYLOAD_TOO_LARGE; + case 41301: return MESSAGE_BODY_TOO_LARGE; + case 42800: return PRECONDITION_FAILED; case 42900: return TOO_MANY_REQUESTS; + case 43100: return REQUEST_HEADER_FIELDS_TOO_LARGE; + case 43101: return MESSAGE_PROPERTIES_TOO_LARGE; case 50000: return INTERNAL_ERROR; case 50001: return INTERNAL_SERVER_ERROR; case 50002: return HA_NOT_AVAILABLE; case 50100: return NOT_IMPLEMENTED; - case 50400: return TIMEOUT; + case 50400: return PROXY_TIMEOUT; case 50401: return MASTER_PERSISTENCE_TIMEOUT; case 50402: return SLAVE_PERSISTENCE_TIMEOUT; - case 50403: return PROXY_TIMEOUT; case 50500: return UNSUPPORTED; case 50501: return VERSION_UNSUPPORTED; case 50502: return VERIFY_FIFO_MESSAGE_UNSUPPORTED; diff --git a/src/main/java/apache/rocketmq/v2/MQDomain.java b/src/main/java/apache/rocketmq/v2/MQDomain.java index 54c75c2..55df293 100644 --- a/src/main/java/apache/rocketmq/v2/MQDomain.java +++ b/src/main/java/apache/rocketmq/v2/MQDomain.java @@ -195,38 +195,41 @@ public final class MQDomain { "entType\022\033\n\027CLIENT_TYPE_UNSPECIFIED\020\000\022\014\n\010" + "PRODUCER\020\001\022\021\n\rPUSH_CONSUMER\020\002\022\023\n\017SIMPLE_" + "CONSUMER\020\003*<\n\010Encoding\022\030\n\024ENCODING_UNSPE" + - "CIFIED\020\000\022\014\n\010IDENTITY\020\001\022\010\n\004GZIP\020\002*\265\010\n\004Cod" + + "CIFIED\020\000\022\014\n\010IDENTITY\020\001\022\010\n\004GZIP\020\002*\247\t\n\004Cod" + "e\022\024\n\020CODE_UNSPECIFIED\020\000\022\010\n\002OK\020\240\234\001\022\026\n\020MUL" + "TIPLE_RESULTS\020\260\352\001\022\021\n\013BAD_REQUEST\020\300\270\002\022\032\n\024" + "ILLEGAL_ACCESS_POINT\020\301\270\002\022\023\n\rILLEGAL_TOPI" + "C\020\302\270\002\022\034\n\026ILLEGAL_CONSUMER_GROUP\020\303\270\002\022\031\n\023I" + "LLEGAL_MESSAGE_TAG\020\304\270\002\022\031\n\023ILLEGAL_MESSAG" + "E_KEY\020\305\270\002\022\033\n\025ILLEGAL_MESSAGE_GROUP\020\306\270\002\022\"" + - "\n\034ILLEGAL_MESSAGE_PROPERTY_KEY\020\307\270\002\022\"\n\034ME" + - "SSAGE_PROPERTIES_TOO_LARGE\020\310\270\002\022\034\n\026MESSAG" + - "E_BODY_TOO_LARGE\020\311\270\002\022\034\n\026INVALID_TRANSACT" + - "ION_ID\020\312\270\002\022\030\n\022ILLEGAL_MESSAGE_ID\020\313\270\002\022\037\n\031" + - "ILLEGAL_FILTER_EXPRESSION\020\314\270\002\022\034\n\026INVALID" + - "_RECEIPT_HANDLE\020\315\270\002\0222\n,MESSAGE_PROPERTY_" + - "DOES_NOT_MATCH_MESSAGE_TYPE\020\316\270\002\022\036\n\030UNREC" + - "OGNIZED_CLIENT_TYPE\020\317\270\002\022\027\n\021MESSAGE_CORRU" + - "PTED\020\320\270\002\022\030\n\022CLIENT_ID_REQUIRED\020\321\270\002\022\022\n\014UN" + - "AUTHORIZED\020\244\271\002\022\017\n\tFORBIDDEN\020\354\272\002\022\017\n\tNOT_F" + - "OUND\020\320\273\002\022\027\n\021MESSAGE_NOT_FOUND\020\321\273\002\022\025\n\017TOP" + - "IC_NOT_FOUND\020\322\273\002\022\036\n\030CONSUMER_GROUP_NOT_F" + - "OUND\020\323\273\002\022\027\n\021TOO_MANY_REQUESTS\020\224\317\002\022\024\n\016INT" + - "ERNAL_ERROR\020\320\206\003\022\033\n\025INTERNAL_SERVER_ERROR" + - "\020\321\206\003\022\026\n\020HA_NOT_AVAILABLE\020\322\206\003\022\025\n\017NOT_IMPL" + - "EMENTED\020\264\207\003\022\r\n\007TIMEOUT\020\340\211\003\022 \n\032MASTER_PER" + - "SISTENCE_TIMEOUT\020\341\211\003\022\037\n\031SLAVE_PERSISTENC" + - "E_TIMEOUT\020\342\211\003\022\023\n\rPROXY_TIMEOUT\020\343\211\003\022\021\n\013UN" + - "SUPPORTED\020\304\212\003\022\031\n\023VERSION_UNSUPPORTED\020\305\212\003" + - "\022%\n\037VERIFY_FIFO_MESSAGE_UNSUPPORTED\020\306\212\003\022" + - "\037\n\031FAILED_TO_CONSUME_MESSAGE\020\340\324\003*Z\n\010Lang" + - "uage\022\030\n\024LANGUAGE_UNSPECIFIED\020\000\022\010\n\004JAVA\020\001" + - "\022\007\n\003CPP\020\002\022\013\n\007DOT_NET\020\003\022\n\n\006GOLANG\020\004\022\010\n\004RU" + - "ST\020\005B;\n\022apache.rocketmq.v2B\010MQDomainP\001\240\001" + - "\001\330\001\001\252\002\022Apache.Rocketmq.V2b\006proto3" + "\n\034ILLEGAL_MESSAGE_PROPERTY_KEY\020\307\270\002\022\034\n\026IN" + + "VALID_TRANSACTION_ID\020\310\270\002\022\030\n\022ILLEGAL_MESS" + + "AGE_ID\020\311\270\002\022\037\n\031ILLEGAL_FILTER_EXPRESSION\020" + + "\312\270\002\022\034\n\026INVALID_RECEIPT_HANDLE\020\313\270\002\022)\n#MES" + + "SAGE_PROPERTY_CONFLICT_WITH_TYPE\020\314\270\002\022\036\n\030" + + "UNRECOGNIZED_CLIENT_TYPE\020\315\270\002\022\027\n\021MESSAGE_" + + "CORRUPTED\020\316\270\002\022\030\n\022CLIENT_ID_REQUIRED\020\317\270\002\022" + + "\022\n\014UNAUTHORIZED\020\244\271\002\022\026\n\020PAYMENT_REQUIRED\020" + + "\210\272\002\022\017\n\tFORBIDDEN\020\354\272\002\022\017\n\tNOT_FOUND\020\320\273\002\022\027\n" + + "\021MESSAGE_NOT_FOUND\020\321\273\002\022\025\n\017TOPIC_NOT_FOUN" + + "D\020\322\273\002\022\036\n\030CONSUMER_GROUP_NOT_FOUND\020\323\273\002\022\025\n" + + "\017REQUEST_TIMEOUT\020\340\276\002\022\027\n\021PAYLOAD_TOO_LARG" + + "E\020\324\302\002\022\034\n\026MESSAGE_BODY_TOO_LARGE\020\325\302\002\022\031\n\023P" + + "RECONDITION_FAILED\020\260\316\002\022\027\n\021TOO_MANY_REQUE" + + "STS\020\224\317\002\022%\n\037REQUEST_HEADER_FIELDS_TOO_LAR" + + "GE\020\334\320\002\022\"\n\034MESSAGE_PROPERTIES_TOO_LARGE\020\335" + + "\320\002\022\024\n\016INTERNAL_ERROR\020\320\206\003\022\033\n\025INTERNAL_SER" + + "VER_ERROR\020\321\206\003\022\026\n\020HA_NOT_AVAILABLE\020\322\206\003\022\025\n" + + "\017NOT_IMPLEMENTED\020\264\207\003\022\023\n\rPROXY_TIMEOUT\020\340\211" + + "\003\022 \n\032MASTER_PERSISTENCE_TIMEOUT\020\341\211\003\022\037\n\031S" + + "LAVE_PERSISTENCE_TIMEOUT\020\342\211\003\022\021\n\013UNSUPPOR" + + "TED\020\304\212\003\022\031\n\023VERSION_UNSUPPORTED\020\305\212\003\022%\n\037VE" + + "RIFY_FIFO_MESSAGE_UNSUPPORTED\020\306\212\003\022\037\n\031FAI" + + "LED_TO_CONSUME_MESSAGE\020\340\324\003*Z\n\010Language\022\030" + + "\n\024LANGUAGE_UNSPECIFIED\020\000\022\010\n\004JAVA\020\001\022\007\n\003CP" + + "P\020\002\022\013\n\007DOT_NET\020\003\022\n\n\006GOLANG\020\004\022\010\n\004RUST\020\005B;" + + "\n\022apache.rocketmq.v2B\010MQDomainP\001\240\001\001\330\001\001\252\002" + + "\022Apache.Rocketmq.V2b\006proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor .internalBuildGeneratedFileFrom(descriptorData, diff --git a/src/main/resources/proto/apache/rocketmq/v2/definition.proto b/src/main/resources/proto/apache/rocketmq/v2/definition.proto index 71dc72b..eb15edf 100644 --- a/src/main/resources/proto/apache/rocketmq/v2/definition.proto +++ b/src/main/resources/proto/apache/rocketmq/v2/definition.proto @@ -317,31 +317,30 @@ enum Code { ILLEGAL_MESSAGE_GROUP = 40006; // Format of message property key is illegal. ILLEGAL_MESSAGE_PROPERTY_KEY = 40007; - // Message properties total size exceeds the threshold. - MESSAGE_PROPERTIES_TOO_LARGE = 40008; - // Message body size exceeds the threshold. - MESSAGE_BODY_TOO_LARGE = 40009; // Transaction id is invalid. - INVALID_TRANSACTION_ID = 40010; + INVALID_TRANSACTION_ID = 40008; // Format of message id is illegal. - ILLEGAL_MESSAGE_ID = 40011; + ILLEGAL_MESSAGE_ID = 40009; // Format of filter expression is illegal. - ILLEGAL_FILTER_EXPRESSION = 40012; + ILLEGAL_FILTER_EXPRESSION = 40010; // Receipt handle of message is invalid. - INVALID_RECEIPT_HANDLE = 40013; - // Message property is not match the message type. - MESSAGE_PROPERTY_DOES_NOT_MATCH_MESSAGE_TYPE = 40014; + INVALID_RECEIPT_HANDLE = 40011; + // Message property conflicts with its type. + MESSAGE_PROPERTY_CONFLICT_WITH_TYPE = 40012; // Client type could not be recognized. - UNRECOGNIZED_CLIENT_TYPE = 40015; + UNRECOGNIZED_CLIENT_TYPE = 40013; // Message is corrupted. - MESSAGE_CORRUPTED = 40016; + MESSAGE_CORRUPTED = 40014; // Request is rejected due to missing of x-mq-client-id header. - CLIENT_ID_REQUIRED = 40017; + CLIENT_ID_REQUIRED = 40015; // Generic code indicates that the client request lacks valid authentication // credentials for the requested resource. UNAUTHORIZED = 40100; + // Generic code indicates that the account is suspended due to overdue of payment. + PAYMENT_REQUIRED = 40200; + // Generic code for the case that user does not have the permission to operate. FORBIDDEN = 40300; @@ -354,10 +353,30 @@ enum Code { // Consumer group resource does not exist. CONSUMER_GROUP_NOT_FOUND = 40403; + // Generic code representing client side timeout when connecting to, reading data from, or write data to server. + REQUEST_TIMEOUT = 40800; + + // Generic code represents that the request entity is larger than limits defined by server. + PAYLOAD_TOO_LARGE = 41300; + + // Message body size exceeds the threshold. + MESSAGE_BODY_TOO_LARGE = 41301; + + // Generic code for use cases where pre-conditions are not met. + // For example, if a producer instance is used to publish messages without prior start() invocation, + // this error code will be raised. + PRECONDITION_FAILED = 42800; + // Generic code indicates that too many requests are made in short period of duration. // Requests are throttled. TOO_MANY_REQUESTS = 42900; + // Generic code for the case that the server is unwilling to process the request because its header fields are too large. + // The request may be resubmitted after reducing the size of the request header fields. + REQUEST_HEADER_FIELDS_TOO_LARGE = 43100; + // Message properties total size exceeds the threshold. + MESSAGE_PROPERTIES_TOO_LARGE = 43101; + // Generic code indicates that server/client encountered an unexpected // condition that prevented it from fulfilling the request. INTERNAL_ERROR = 50000; @@ -378,17 +397,15 @@ enum Code { // functionality required to fulfill the request. NOT_IMPLEMENTED = 50100; - // Generic code for timeout. - TIMEOUT = 50400; + // Generic code represents that the server, which acts as a gateway or proxy, + // does not get an satisfied response in time from its upstream servers. + PROXY_TIMEOUT = 50400; // Message persistence timeout. MASTER_PERSISTENCE_TIMEOUT = 50401; // Slave persistence timeout. SLAVE_PERSISTENCE_TIMEOUT = 50402; - // Code indicates that the server, while acting as a gateway or proxy, - // did not get a response in time from the upstream server that - // it needed in order to complete the request. - PROXY_TIMEOUT = 50403; + // Generic code for unsupported operation. UNSUPPORTED = 50500; // Operation is not allowed in current version. VERSION_UNSUPPORTED = 50501;
