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 fd1c1e092b03a00a1fa45eeb7c4c723e632dd6dc Author: 凌楚 <[email protected]> AuthorDate: Mon Jul 11 16:35:34 2022 +0800 Apply IDL update --- src/main/java/apache/rocketmq/v2/Code.java | 84 +++++++++++++++------- src/main/java/apache/rocketmq/v2/MQDomain.java | 54 +++++++------- .../proto/apache/rocketmq/v2/definition.proto | 14 ++-- 3 files changed, 96 insertions(+), 56 deletions(-) diff --git a/src/main/java/apache/rocketmq/v2/Code.java b/src/main/java/apache/rocketmq/v2/Code.java index 14fa654..5bc0acb 100644 --- a/src/main/java/apache/rocketmq/v2/Code.java +++ b/src/main/java/apache/rocketmq/v2/Code.java @@ -116,46 +116,62 @@ public enum Code * <code>ILLEGAL_FILTER_EXPRESSION = 40010;</code> */ ILLEGAL_FILTER_EXPRESSION(40010), + /** + * <pre> + * The invisible time of request is invalid. + * </pre> + * + * <code>ILLEGAL_INVISIBLE_TIME = 40011;</code> + */ + ILLEGAL_INVISIBLE_TIME(40011), + /** + * <pre> + * The delivery timestamp of message is invalid. + * </pre> + * + * <code>ILLEGAL_DELIVERY_TIME = 40012;</code> + */ + ILLEGAL_DELIVERY_TIME(40012), /** * <pre> * Receipt handle of message is invalid. * </pre> * - * <code>INVALID_RECEIPT_HANDLE = 40011;</code> + * <code>INVALID_RECEIPT_HANDLE = 40013;</code> */ - INVALID_RECEIPT_HANDLE(40011), + INVALID_RECEIPT_HANDLE(40013), /** * <pre> * Message property conflicts with its type. * </pre> * - * <code>MESSAGE_PROPERTY_CONFLICT_WITH_TYPE = 40012;</code> + * <code>MESSAGE_PROPERTY_CONFLICT_WITH_TYPE = 40014;</code> */ - MESSAGE_PROPERTY_CONFLICT_WITH_TYPE(40012), + MESSAGE_PROPERTY_CONFLICT_WITH_TYPE(40014), /** * <pre> * Client type could not be recognized. * </pre> * - * <code>UNRECOGNIZED_CLIENT_TYPE = 40013;</code> + * <code>UNRECOGNIZED_CLIENT_TYPE = 40015;</code> */ - UNRECOGNIZED_CLIENT_TYPE(40013), + UNRECOGNIZED_CLIENT_TYPE(40015), /** * <pre> * Message is corrupted. * </pre> * - * <code>MESSAGE_CORRUPTED = 40014;</code> + * <code>MESSAGE_CORRUPTED = 40016;</code> */ - MESSAGE_CORRUPTED(40014), + MESSAGE_CORRUPTED(40016), /** * <pre> * Request is rejected due to missing of x-mq-client-id header. * </pre> * - * <code>CLIENT_ID_REQUIRED = 40015;</code> + * <code>CLIENT_ID_REQUIRED = 40017;</code> */ - CLIENT_ID_REQUIRED(40015), + CLIENT_ID_REQUIRED(40017), /** * <pre> * Generic code indicates that the client request lacks valid authentication @@ -484,46 +500,62 @@ public enum Code * <code>ILLEGAL_FILTER_EXPRESSION = 40010;</code> */ public static final int ILLEGAL_FILTER_EXPRESSION_VALUE = 40010; + /** + * <pre> + * The invisible time of request is invalid. + * </pre> + * + * <code>ILLEGAL_INVISIBLE_TIME = 40011;</code> + */ + public static final int ILLEGAL_INVISIBLE_TIME_VALUE = 40011; + /** + * <pre> + * The delivery timestamp of message is invalid. + * </pre> + * + * <code>ILLEGAL_DELIVERY_TIME = 40012;</code> + */ + public static final int ILLEGAL_DELIVERY_TIME_VALUE = 40012; /** * <pre> * Receipt handle of message is invalid. * </pre> * - * <code>INVALID_RECEIPT_HANDLE = 40011;</code> + * <code>INVALID_RECEIPT_HANDLE = 40013;</code> */ - public static final int INVALID_RECEIPT_HANDLE_VALUE = 40011; + public static final int INVALID_RECEIPT_HANDLE_VALUE = 40013; /** * <pre> * Message property conflicts with its type. * </pre> * - * <code>MESSAGE_PROPERTY_CONFLICT_WITH_TYPE = 40012;</code> + * <code>MESSAGE_PROPERTY_CONFLICT_WITH_TYPE = 40014;</code> */ - public static final int MESSAGE_PROPERTY_CONFLICT_WITH_TYPE_VALUE = 40012; + public static final int MESSAGE_PROPERTY_CONFLICT_WITH_TYPE_VALUE = 40014; /** * <pre> * Client type could not be recognized. * </pre> * - * <code>UNRECOGNIZED_CLIENT_TYPE = 40013;</code> + * <code>UNRECOGNIZED_CLIENT_TYPE = 40015;</code> */ - public static final int UNRECOGNIZED_CLIENT_TYPE_VALUE = 40013; + public static final int UNRECOGNIZED_CLIENT_TYPE_VALUE = 40015; /** * <pre> * Message is corrupted. * </pre> * - * <code>MESSAGE_CORRUPTED = 40014;</code> + * <code>MESSAGE_CORRUPTED = 40016;</code> */ - public static final int MESSAGE_CORRUPTED_VALUE = 40014; + public static final int MESSAGE_CORRUPTED_VALUE = 40016; /** * <pre> * Request is rejected due to missing of x-mq-client-id header. * </pre> * - * <code>CLIENT_ID_REQUIRED = 40015;</code> + * <code>CLIENT_ID_REQUIRED = 40017;</code> */ - public static final int CLIENT_ID_REQUIRED_VALUE = 40015; + public static final int CLIENT_ID_REQUIRED_VALUE = 40017; /** * <pre> * Generic code indicates that the client request lacks valid authentication @@ -781,11 +813,13 @@ public enum Code 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 40011: return ILLEGAL_INVISIBLE_TIME; + case 40012: return ILLEGAL_DELIVERY_TIME; + case 40013: return INVALID_RECEIPT_HANDLE; + case 40014: return MESSAGE_PROPERTY_CONFLICT_WITH_TYPE; + case 40015: return UNRECOGNIZED_CLIENT_TYPE; + case 40016: return MESSAGE_CORRUPTED; + case 40017: return CLIENT_ID_REQUIRED; case 40100: return UNAUTHORIZED; case 40200: return PAYMENT_REQUIRED; case 40300: return FORBIDDEN; diff --git a/src/main/java/apache/rocketmq/v2/MQDomain.java b/src/main/java/apache/rocketmq/v2/MQDomain.java index 55df293..ce81f77 100644 --- a/src/main/java/apache/rocketmq/v2/MQDomain.java +++ b/src/main/java/apache/rocketmq/v2/MQDomain.java @@ -195,7 +195,7 @@ 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*\247\t\n\004Cod" + + "CIFIED\020\000\022\014\n\010IDENTITY\020\001\022\010\n\004GZIP\020\002*\342\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" + @@ -205,31 +205,33 @@ public final class MQDomain { "\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" + "\312\270\002\022\034\n\026ILLEGAL_INVISIBLE_TIME\020\313\270\002\022\033\n\025ILL" + + "EGAL_DELIVERY_TIME\020\314\270\002\022\034\n\026INVALID_RECEIP" + + "T_HANDLE\020\315\270\002\022)\n#MESSAGE_PROPERTY_CONFLIC" + + "T_WITH_TYPE\020\316\270\002\022\036\n\030UNRECOGNIZED_CLIENT_T" + + "YPE\020\317\270\002\022\027\n\021MESSAGE_CORRUPTED\020\320\270\002\022\030\n\022CLIE" + + "NT_ID_REQUIRED\020\321\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_FOUND\020\322\273\002\022\036\n\030CONSUMER_GRO" + + "UP_NOT_FOUND\020\323\273\002\022\025\n\017REQUEST_TIMEOUT\020\340\276\002\022" + + "\027\n\021PAYLOAD_TOO_LARGE\020\324\302\002\022\034\n\026MESSAGE_BODY" + + "_TOO_LARGE\020\325\302\002\022\031\n\023PRECONDITION_FAILED\020\260\316" + + "\002\022\027\n\021TOO_MANY_REQUESTS\020\224\317\002\022%\n\037REQUEST_HE" + + "ADER_FIELDS_TOO_LARGE\020\334\320\002\022\"\n\034MESSAGE_PRO" + + "PERTIES_TOO_LARGE\020\335\320\002\022\024\n\016INTERNAL_ERROR\020" + + "\320\206\003\022\033\n\025INTERNAL_SERVER_ERROR\020\321\206\003\022\026\n\020HA_N" + + "OT_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_PERSISTEN" + + "CE_TIMEOUT\020\341\211\003\022\037\n\031SLAVE_PERSISTENCE_TIME" + + "OUT\020\342\211\003\022\021\n\013UNSUPPORTED\020\304\212\003\022\031\n\023VERSION_UN" + + "SUPPORTED\020\305\212\003\022%\n\037VERIFY_FIFO_MESSAGE_UNS" + + "UPPORTED\020\306\212\003\022\037\n\031FAILED_TO_CONSUME_MESSAG" + + "E\020\340\324\003*Z\n\010Language\022\030\n\024LANGUAGE_UNSPECIFIE" + + "D\020\000\022\010\n\004JAVA\020\001\022\007\n\003CPP\020\002\022\013\n\007DOT_NET\020\003\022\n\n\006G" + + "OLANG\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\006" + + "proto3" }; 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 5fac48f..ffc3839 100644 --- a/src/main/resources/proto/apache/rocketmq/v2/definition.proto +++ b/src/main/resources/proto/apache/rocketmq/v2/definition.proto @@ -323,16 +323,20 @@ enum Code { ILLEGAL_MESSAGE_ID = 40009; // Format of filter expression is illegal. ILLEGAL_FILTER_EXPRESSION = 40010; + // The invisible time of request is invalid. + ILLEGAL_INVISIBLE_TIME = 40011; + // The delivery timestamp of message is invalid. + ILLEGAL_DELIVERY_TIME = 40012; // Receipt handle of message is invalid. - INVALID_RECEIPT_HANDLE = 40011; + INVALID_RECEIPT_HANDLE = 40013; // Message property conflicts with its type. - MESSAGE_PROPERTY_CONFLICT_WITH_TYPE = 40012; + MESSAGE_PROPERTY_CONFLICT_WITH_TYPE = 40014; // Client type could not be recognized. - UNRECOGNIZED_CLIENT_TYPE = 40013; + UNRECOGNIZED_CLIENT_TYPE = 40015; // Message is corrupted. - MESSAGE_CORRUPTED = 40014; + MESSAGE_CORRUPTED = 40016; // Request is rejected due to missing of x-mq-client-id header. - CLIENT_ID_REQUIRED = 40015; + CLIENT_ID_REQUIRED = 40017; // Generic code indicates that the client request lacks valid authentication // credentials for the requested resource.
