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 765ca0f55f38c6d64c2ede7829e624b09fb582ee Author: 凌楚 <[email protected]> AuthorDate: Mon May 23 15:29:12 2022 +0800 Apply IDL update --- src/main/java/apache/rocketmq/v2/Code.java | 17 +++++++++++++++++ src/main/java/apache/rocketmq/v2/MQDomain.java | 17 +++++++++-------- .../resources/proto/apache/rocketmq/v2/definition.proto | 3 +++ 3 files changed, 29 insertions(+), 8 deletions(-) diff --git a/src/main/java/apache/rocketmq/v2/Code.java b/src/main/java/apache/rocketmq/v2/Code.java index 5694422..51e00cd 100644 --- a/src/main/java/apache/rocketmq/v2/Code.java +++ b/src/main/java/apache/rocketmq/v2/Code.java @@ -280,6 +280,14 @@ public enum Code * <code>UNRECOGNIZED_CLIENT_TYPE = 32;</code> */ UNRECOGNIZED_CLIENT_TYPE(32), + /** + * <pre> + * Return different results for entries in composite request. + * </pre> + * + * <code>MULTIPLE_RESULTS = 33;</code> + */ + MULTIPLE_RESULTS(33), /** * <pre> * Code indicates that the server encountered an unexpected condition @@ -590,6 +598,14 @@ public enum Code * <code>UNRECOGNIZED_CLIENT_TYPE = 32;</code> */ public static final int UNRECOGNIZED_CLIENT_TYPE_VALUE = 32; + /** + * <pre> + * Return different results for entries in composite request. + * </pre> + * + * <code>MULTIPLE_RESULTS = 33;</code> + */ + public static final int MULTIPLE_RESULTS_VALUE = 33; /** * <pre> * Code indicates that the server encountered an unexpected condition @@ -684,6 +700,7 @@ public enum Code case 30: return ILLEGAL_MESSAGE_OFFSET; case 31: return ILLEGAL_MESSAGE; case 32: return UNRECOGNIZED_CLIENT_TYPE; + case 33: return MULTIPLE_RESULTS; case 500: return INTERNAL_SERVER_ERROR; case 501: return NOT_IMPLEMENTED; case 504: return GATEWAY_TIMEOUT; diff --git a/src/main/java/apache/rocketmq/v2/MQDomain.java b/src/main/java/apache/rocketmq/v2/MQDomain.java index ddac52b..dee123f 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*\272\007\n\004Cod" + + "CIFIED\020\000\022\014\n\010IDENTITY\020\001\022\010\n\004GZIP\020\002*\320\007\n\004Cod" + "e\022\006\n\002OK\020\000\022\030\n\024ILLEGAL_ACCESS_POINT\020\001\022\021\n\rI" + "LLEGAL_TOPIC\020\002\022\032\n\026ILLEGAL_CONSUMER_GROUP" + "\020\003\022\027\n\023ILLEGAL_MESSAGE_TAG\020\004\022\027\n\023ILLEGAL_M" + @@ -217,13 +217,14 @@ public final class MQDomain { "IMEOUT\020\032\022\024\n\020HA_NOT_AVAILABLE\020\033\022\027\n\023VERSIO" + "N_UNSUPPORTED\020\034\022\025\n\021MESSAGE_NOT_FOUND\020\035\022\032" + "\n\026ILLEGAL_MESSAGE_OFFSET\020\036\022\023\n\017ILLEGAL_ME" + - "SSAGE\020\037\022\034\n\030UNRECOGNIZED_CLIENT_TYPE\020 \022\032\n" + - "\025INTERNAL_SERVER_ERROR\020\364\003\022\024\n\017NOT_IMPLEME" + - "NTED\020\365\003\022\024\n\017GATEWAY_TIMEOUT\020\370\003*Z\n\010Languag" + - "e\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\004RUST\020" + - "\005B;\n\022apache.rocketmq.v2B\010MQDomainP\001\240\001\001\330\001" + - "\001\252\002\022Apache.Rocketmq.V2b\006proto3" + "SSAGE\020\037\022\034\n\030UNRECOGNIZED_CLIENT_TYPE\020 \022\024\n" + + "\020MULTIPLE_RESULTS\020!\022\032\n\025INTERNAL_SERVER_E" + + "RROR\020\364\003\022\024\n\017NOT_IMPLEMENTED\020\365\003\022\024\n\017GATEWAY" + + "_TIMEOUT\020\370\003*Z\n\010Language\022\030\n\024LANGUAGE_UNSP" + + "ECIFIED\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\004RUST\020\005B;\n\022apache.rocket" + + "mq.v2B\010MQDomainP\001\240\001\001\330\001\001\252\002\022Apache.Rocketm" + + "q.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 3153638..21a6321 100644 --- a/src/main/resources/proto/apache/rocketmq/v2/definition.proto +++ b/src/main/resources/proto/apache/rocketmq/v2/definition.proto @@ -388,6 +388,9 @@ enum Code { // Client type could not be recognized. UNRECOGNIZED_CLIENT_TYPE = 32; + // Return different results for entries in composite request. + MULTIPLE_RESULTS = 33; + // Code indicates that the server encountered an unexpected condition // that prevented it from fulfilling the request. // This error response is a generic "catch-all" response.
