You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2022/07/15 03:28:06 UTC
[rocketmq-apis] 33/38: Apply IDL update
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: 凌楚 <ya...@alibaba-inc.com>
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.